Package org.nuxeo.ecm.core.event.pipe.local

Class LocalEventBundlePipeConsumer

java.lang.Object

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

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

org.nuxeo.ecm.core.event.pipe.local.LocalEventBundlePipeConsumer

All Implemented Interfaces:

PipeConsumer<EventBundle>

@Experimental
public class LocalEventBundlePipeConsumer
extends AbstractListenerPipeConsumer<EventBundle>

In memory implementation that does not handle any marshaling and directly feeds the WorkManager.

Since:

8.4

Field Summary

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

asyncExec, stopping

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

name, params

Constructor Summary

Constructors

Constructor	Description
LocalEventBundlePipeConsumer()

Method Summary

Modifier and Type	Method	Description
protected List<EventBundle>	unmarshallEventBundle(List<EventBundle> messages)

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

initConsumer, processEventBundles, shutdown, waitForCompletion

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

getName, getParameters, receiveMessage

Methods inherited from class java.lang.Object

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

Constructor Details

LocalEventBundlePipeConsumer

public LocalEventBundlePipeConsumer()

Method Details

unmarshallEventBundle

protected List<EventBundle> unmarshallEventBundle(List<EventBundle> messages)

Specified by:

unmarshallEventBundle in class AbstractPipeConsumer<EventBundle>