Interface EventBundleDispatcher
-
- All Known Implementing Classes:
SimpleEventBundlePipeDispatcher
public interface EventBundleDispatcher
Interface for dispatchingEventBundle
between differentEventBundlePipe
- Since:
- 8.4
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
init(List<EventPipeDescriptor> pipeDescriptors, Map<String,String> parameters)
Initialize the dispatchervoid
sendEventBundle(EventBundle events)
Forward anEventBundle
to the underlyingEventBundlePipe
svoid
shutdown()
Shutdown callbackboolean
waitForCompletion(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 underlyingEventBundlePipe
s
-
sendEventBundle
void sendEventBundle(EventBundle events)
Forward anEventBundle
to the underlyingEventBundlePipe
s
-
waitForCompletion
boolean waitForCompletion(long timeoutMillis) throws InterruptedException
Wait until the end of processing- Throws:
InterruptedException
-
shutdown
void shutdown() throws InterruptedException
Shutdown callback- Throws:
InterruptedException
-
-