public class SimpleEventBundlePipeDispatcher extends Object implements EventBundleDispatcher
EventBundle
to all underlying EventBundlePipe
Modifier and Type | Field and Description |
---|---|
protected Map<String,String> |
parameters |
protected List<EventBundlePipe> |
pipes |
Constructor and Description |
---|
SimpleEventBundlePipeDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
init(List<EventPipeDescriptor> pipeDescriptors,
Map<String,String> parameters)
Initialize the dispatcher
|
void |
sendEventBundle(EventBundle events)
Forward an
EventBundle to the underlying EventBundlePipe s |
void |
shutdown()
Shutdown callback
|
boolean |
waitForCompletion(long timeoutMillis)
Wait until the end of processing
|
protected List<EventBundlePipe> pipes
protected Map<String,String> parameters
public SimpleEventBundlePipeDispatcher()
public void init(List<EventPipeDescriptor> pipeDescriptors, Map<String,String> parameters)
EventBundleDispatcher
init
in interface EventBundleDispatcher
pipeDescriptors
- descriptors of the underlying EventBundlePipe
spublic void sendEventBundle(EventBundle events)
EventBundleDispatcher
EventBundle
to the underlying EventBundlePipe
ssendEventBundle
in interface EventBundleDispatcher
public boolean waitForCompletion(long timeoutMillis) throws InterruptedException
EventBundleDispatcher
waitForCompletion
in interface EventBundleDispatcher
InterruptedException
public void shutdown() throws InterruptedException
EventBundleDispatcher
shutdown
in interface EventBundleDispatcher
InterruptedException
Copyright © 2016 Nuxeo SA. All rights reserved.