@Experimental public class LocalEventBundlePipe extends AbstractEventBundlePipe<EventBundle> implements EventBundlePipe
Modifier and Type | Field and Description |
---|---|
protected LocalEventBundlePipeConsumer |
consumer |
name, params
Constructor and Description |
---|
LocalEventBundlePipe() |
Modifier and Type | Method and 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
|
filterBundle, getName, getParameters, preProcessBundle, sendEventBundle, shutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
sendEventBundle, shutdown
protected LocalEventBundlePipeConsumer consumer
public LocalEventBundlePipe()
public void initPipe(String name, Map<String,String> params)
EventBundlePipe
initPipe
in interface EventBundlePipe
initPipe
in class AbstractEventBundlePipe<EventBundle>
name
- the name as defined in the XMap descriptorparams
- the parameters as defined in the XMap descriptorprotected void send(EventBundle message)
AbstractEventBundlePipe
send
in class AbstractEventBundlePipe<EventBundle>
protected EventBundle marshall(EventBundle events)
AbstractEventBundlePipe
marshall
in class AbstractEventBundlePipe<EventBundle>
public boolean waitForCompletion(long timeoutMillis) throws InterruptedException
EventBundlePipe
waitForCompletion
in interface EventBundlePipe
InterruptedException
Copyright © 2019 Nuxeo. All rights reserved.