Package org.nuxeo.ecm.core.event.pipe
Interface PipeConsumer<T>
- All Known Implementing Classes:
AbstractListenerPipeConsumer
,AbstractPipeConsumer
,LocalEventBundlePipeConsumer
public interface PipeConsumer<T>
SPI for a consumer of messages inside the
EventBundlePipe
- Since:
- 8.4
-
Method Summary
Modifier and TypeMethodDescriptionvoid
initConsumer
(String name, Map<String, String> params) Initialize the Consumer when theEventBundlePipe
is initializedboolean
receiveMessage
(List<T> messages) Callback when a batch of messages is availablevoid
shutdown()
Shutdown the consumer when theEventBundlePipe
is shutdownboolean
waitForCompletion
(long timeoutMillis) Wait until consumer is done
-
Method Details
-
initConsumer
Initialize the Consumer when theEventBundlePipe
is initialized -
receiveMessage
Callback when a batch of messages is available -
shutdown
Shutdown the consumer when theEventBundlePipe
is shutdown- Throws:
InterruptedException
-
waitForCompletion
Wait until consumer is done- Throws:
InterruptedException
-