Class SimpleEventBundlePipeDispatcher
java.lang.Object
org.nuxeo.ecm.core.event.pipe.dispatch.SimpleEventBundlePipeDispatcher
- All Implemented Interfaces:
EventBundleDispatcher
Basic implementation that simply forwards
EventBundle
to all underlying EventBundlePipe
- Since:
- 8.4
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Initialize the dispatchervoid
sendEventBundle
(EventBundle events) Forward anEventBundle
to the underlyingEventBundlePipe
svoid
shutdown()
Shutdown callbackboolean
waitForCompletion
(long timeoutMillis) Wait until the end of processing
-
Field Details
-
pipes
-
parameters
-
-
Constructor Details
-
SimpleEventBundlePipeDispatcher
public SimpleEventBundlePipeDispatcher()
-
-
Method Details
-
init
Description copied from interface:EventBundleDispatcher
Initialize the dispatcher- Specified by:
init
in interfaceEventBundleDispatcher
- Parameters:
pipeDescriptors
- descriptors of the underlyingEventBundlePipe
s
-
sendEventBundle
Description copied from interface:EventBundleDispatcher
Forward anEventBundle
to the underlyingEventBundlePipe
s- Specified by:
sendEventBundle
in interfaceEventBundleDispatcher
-
waitForCompletion
Description copied from interface:EventBundleDispatcher
Wait until the end of processing- Specified by:
waitForCompletion
in interfaceEventBundleDispatcher
- Throws:
InterruptedException
-
shutdown
Description copied from interface:EventBundleDispatcher
Shutdown callback- Specified by:
shutdown
in interfaceEventBundleDispatcher
- Throws:
InterruptedException
-