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 an Externalizable with an identifier.

  • Method Summary

    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 Details

    • 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.