org.nuxeo.lib.stream.pattern

Interface Message

All Superinterfaces:

Externalizable, Serializable

All Known Implementing Classes:

BlobInfoMessage, BlobMessage, DocumentMessage, KeyValueMessage

public interface Message
extends Externalizable

A message is an Externalizable with an identifier.

Method Summary

Modifier and Type	Method and Description
default boolean	forceBatch() A consumer reading this message must not wait for new message to process the batch.
String	getId() A message identifier.
default boolean	poisonPill() This message is a poison pill it contains no other data, a consumer reading this message will process the batch and stop.

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Method Detail

getId

String getId()

A message identifier.

forceBatch

default boolean forceBatch()

A consumer reading this message must not wait for new message to process the batch.

poisonPill

default boolean poisonPill()

This message is a poison pill it contains no other data, a consumer reading this message will process the batch and stop.