public abstract class AbstractListenerPipeConsumer<T> extends AbstractPipeConsumer<T>
EventBundle
EventBundles by running asynchronous EventListener
Modifier and Type | Field and Description |
---|---|
protected AsyncEventExecutor |
asyncExec |
protected boolean |
stopping |
name, params
Constructor and Description |
---|
AbstractListenerPipeConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
initConsumer(String name,
Map<String,String> params)
Initialize the Consumer when the
EventBundlePipe is initialized |
protected boolean |
processEventBundles(List<EventBundle> bundles) |
void |
shutdown()
Shutdown the consumer when the
EventBundlePipe is shutdown |
boolean |
waitForCompletion(long timeoutMillis)
Wait until consumer is done
|
getName, getParameters, receiveMessage, unmarshallEventBundle
protected volatile AsyncEventExecutor asyncExec
protected boolean stopping
public AbstractListenerPipeConsumer()
public void initConsumer(String name, Map<String,String> params)
PipeConsumer
EventBundlePipe
is initializedinitConsumer
in interface PipeConsumer<T>
initConsumer
in class AbstractPipeConsumer<T>
public void shutdown() throws InterruptedException
PipeConsumer
EventBundlePipe
is shutdownInterruptedException
protected boolean processEventBundles(List<EventBundle> bundles)
processEventBundles
in class AbstractPipeConsumer<T>
public boolean waitForCompletion(long timeoutMillis) throws InterruptedException
PipeConsumer
InterruptedException
Copyright © 2018 Nuxeo. All rights reserved.