Package org.nuxeo.ecm.core.event.pipe
Class AbstractListenerPipeConsumer<T>
java.lang.Object
org.nuxeo.ecm.core.event.pipe.AbstractPipeConsumer<T>
org.nuxeo.ecm.core.event.pipe.AbstractListenerPipeConsumer<T>
- All Implemented Interfaces:
PipeConsumer<T>
- Direct Known Subclasses:
LocalEventBundlePipeConsumer
Consumes
EventBundle
EventBundles by running asynchronous EventListener
- Since:
- 8.4
-
Field Summary
Fields inherited from class org.nuxeo.ecm.core.event.pipe.AbstractPipeConsumer
name, params
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
initConsumer
(String name, Map<String, String> params) Initialize the Consumer when theEventBundlePipe
is initializedprotected boolean
processEventBundles
(List<EventBundle> bundles) void
shutdown()
Shutdown the consumer when theEventBundlePipe
is shutdownboolean
waitForCompletion
(long timeoutMillis) Wait until consumer is doneMethods inherited from class org.nuxeo.ecm.core.event.pipe.AbstractPipeConsumer
getName, getParameters, receiveMessage, unmarshallEventBundle
-
Field Details
-
asyncExec
-
stopping
protected boolean stopping
-
-
Constructor Details
-
AbstractListenerPipeConsumer
public AbstractListenerPipeConsumer()
-
-
Method Details
-
initConsumer
Description copied from interface:PipeConsumer
Initialize the Consumer when theEventBundlePipe
is initialized- Specified by:
initConsumer
in interfacePipeConsumer<T>
- Overrides:
initConsumer
in classAbstractPipeConsumer<T>
-
shutdown
Description copied from interface:PipeConsumer
Shutdown the consumer when theEventBundlePipe
is shutdown- Throws:
InterruptedException
-
processEventBundles
- Specified by:
processEventBundles
in classAbstractPipeConsumer<T>
-
waitForCompletion
Description copied from interface:PipeConsumer
Wait until consumer is done- Throws:
InterruptedException
-