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 anExternalizable
with an identifier.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method 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.
-
-