Interface EventBundleDispatcher
-
- All Known Implementing Classes:
SimpleEventBundlePipeDispatcher
public interface EventBundleDispatcherInterface for dispatchingEventBundlebetween differentEventBundlePipe- Since:
- 8.4
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidinit(List<EventPipeDescriptor> pipeDescriptors, Map<String,String> parameters)Initialize the dispatchervoidsendEventBundle(EventBundle events)Forward anEventBundleto the underlyingEventBundlePipesvoidshutdown()Shutdown callbackbooleanwaitForCompletion(long timeoutMillis)Wait until the end of processing
-
-
-
Method Detail
-
init
void init(List<EventPipeDescriptor> pipeDescriptors, Map<String,String> parameters)
Initialize the dispatcher- Parameters:
pipeDescriptors- descriptors of the underlyingEventBundlePipes
-
sendEventBundle
void sendEventBundle(EventBundle events)
Forward anEventBundleto the underlyingEventBundlePipes
-
waitForCompletion
boolean waitForCompletion(long timeoutMillis) throws InterruptedExceptionWait until the end of processing- Throws:
InterruptedException
-
shutdown
void shutdown() throws InterruptedExceptionShutdown callback- Throws:
InterruptedException
-
-