org.nuxeo.ecm.core.event.pipe

Class AbstractListenerPipeConsumer<T>

java.lang.Object

org.nuxeo.ecm.core.event.pipe.AbstractPipeConsumer<T>

org.nuxeo.ecm.core.event.pipe.AbstractListenerPipeConsumer<T>

All Implemented Interfaces:

PipeConsumer<T>

Direct Known Subclasses:

LocalEventBundlePipeConsumer

public abstract class AbstractListenerPipeConsumer<T>
extends AbstractPipeConsumer<T>

Consumes EventBundle EventBundles by running asynchronous EventListener

Since:

8.4

Field Summary

Fields

Modifier and Type	Field and Description
protected AsyncEventExecutor	asyncExec
protected boolean	stopping

Fields inherited from class org.nuxeo.ecm.core.event.pipe.AbstractPipeConsumer

name, params

Constructor Summary

Constructors

Constructor and Description
AbstractListenerPipeConsumer()

Method Summary

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

Methods inherited from class org.nuxeo.ecm.core.event.pipe.AbstractPipeConsumer

getName, getParameters, receiveMessage, unmarshallEventBundle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

asyncExec

protected volatile AsyncEventExecutor asyncExec

stopping

protected boolean stopping

Constructor Detail

AbstractListenerPipeConsumer

public AbstractListenerPipeConsumer()

Method Detail

initConsumer

public void initConsumer(String name,
                         Map<String,String> params)

Description copied from interface: PipeConsumer

Initialize the Consumer when the EventBundlePipe is initialized

Specified by:

initConsumer in interface PipeConsumer<T>

Overrides:

initConsumer in class AbstractPipeConsumer<T>

shutdown

public void shutdown()
              throws InterruptedException

Description copied from interface: PipeConsumer

Shutdown the consumer when the EventBundlePipe is shutdown

Throws:

InterruptedException

processEventBundles

protected boolean processEventBundles(List<EventBundle> bundles)

Specified by:

processEventBundles in class AbstractPipeConsumer<T>

waitForCompletion

public boolean waitForCompletion(long timeoutMillis)
                          throws InterruptedException

Description copied from interface: PipeConsumer

Wait until consumer is done

Returns:

Throws:

InterruptedException