org.nuxeo.lib.stream.pattern.consumer

Interface Consumer<M extends Message>

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

AbstractConsumer, BlobMessageConsumer, BlobWatermarkMessageConsumer, DocumentMessageConsumer, RedisDocumentMessageConsumer

public interface Consumer<M extends Message>
extends AutoCloseable

A consumer consumes Message by batch.

Since:

9.1

Method Summary

Modifier and Type	Method and Description
void	accept(M message) Consume a message.
void	begin() Begin a batch of messages.
void	commit() End of the batch message.
void	rollback() Called when there is an exception during accept(Message) or commit().

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

begin

void begin()

Begin a batch of messages.

accept

void accept(M message)

Consume a message.

commit

void commit()

End of the batch message.

rollback

void rollback()

Called when there is an exception during accept(Message) or commit().