Package 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 anExternalizablewith an identifier.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default booleanforceBatch()A consumer reading this message must not wait for new message to process the batch.StringgetId()A message identifier.default booleanpoisonPill()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.
-
-