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

Class LocalEventBundlePipe

java.lang.Object

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

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

All Implemented Interfaces:

EventBundlePipe

@Experimental
public class LocalEventBundlePipe
extends AbstractEventBundlePipe<EventBundle>
implements EventBundlePipe

Local In memory implementation: directly relays to WorkManager

Since:

8.4

Field Summary

Fields

Modifier and Type	Field	Description
protected LocalEventBundlePipeConsumer	consumer

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

name, params

Constructor Summary

Constructors

Constructor	Description
LocalEventBundlePipe()

Method Summary

Modifier and Type	Method	Description
void	initPipe(String name, Map<String,String> params)	Initialize the Pipe when Nuxeo Event Service starts
protected EventBundle	marshall(EventBundle events)	de-hydrate the EventBundle to make it suitable for transmission on a Bus
protected void	send(EventBundle message)	Do the actual push on the Bus
boolean	waitForCompletion(long timeoutMillis)	Wait until the end of event consumption

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

filterBundle, getName, getParameters, preProcessBundle, sendEventBundle, shutdown

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.ecm.core.event.pipe.EventBundlePipe

sendEventBundle, shutdown

Field Details

consumer

protected LocalEventBundlePipeConsumer consumer

Constructor Details

LocalEventBundlePipe

public LocalEventBundlePipe()

Method Details

initPipe

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

Description copied from interface: EventBundlePipe

Initialize the Pipe when Nuxeo Event Service starts

Specified by:

initPipe in interface EventBundlePipe

Overrides:

initPipe in class AbstractEventBundlePipe<EventBundle>

Parameters:

name - the name as defined in the XMap descriptor

params - the parameters as defined in the XMap descriptor

send

protected void send(EventBundle message)

Description copied from class: AbstractEventBundlePipe

Do the actual push on the Bus

Specified by:

send in class AbstractEventBundlePipe<EventBundle>

marshall

protected EventBundle marshall(EventBundle events)

Description copied from class: AbstractEventBundlePipe

de-hydrate the EventBundle to make it suitable for transmission on a Bus

Specified by:

marshall in class AbstractEventBundlePipe<EventBundle>

waitForCompletion

public boolean waitForCompletion(long timeoutMillis)
                          throws InterruptedException

Description copied from interface: EventBundlePipe

Wait until the end of event consumption

Specified by:

waitForCompletion in interface EventBundlePipe

Throws:

InterruptedException