public abstract class AbstractEventBundlePipe<T> extends Object implements EventBundlePipe
Modifier and Type | Field and Description |
---|---|
protected String |
name |
protected Map<String,String> |
params |
Constructor and Description |
---|
AbstractEventBundlePipe() |
Modifier and Type | Method and Description |
---|---|
protected EventBundle |
filterBundle(EventBundle events) |
protected String |
getName() |
protected Map<String,String> |
getParameters() |
void |
initPipe(String name,
Map<String,String> params)
Initialize the Pipe when Nuxeo Event Service starts
|
protected abstract T |
marshall(EventBundle events)
de-hydrate the EventBundle to make it suitable for transmission on a Bus
|
protected void |
preProcessBundle(EventBundle events) |
protected abstract void |
send(T message)
Do the actual push on the Bus
|
void |
sendEventBundle(EventBundle events)
Send an
EventBundle inside the pipe |
void |
shutdown()
Shutdown callback when the
EventService stops |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
waitForCompletion
public AbstractEventBundlePipe()
public void initPipe(String name, Map<String,String> params)
EventBundlePipe
initPipe
in interface EventBundlePipe
name
- the name as defined in the XMap descriptorparams
- the parameters as defined in the XMap descriptorprotected Map<String,String> getParameters()
public void sendEventBundle(EventBundle events)
EventBundlePipe
EventBundle
inside the pipesendEventBundle
in interface EventBundlePipe
protected EventBundle filterBundle(EventBundle events)
protected void preProcessBundle(EventBundle events)
protected abstract T marshall(EventBundle events)
events
- public void shutdown() throws InterruptedException
EventBundlePipe
EventService
stopsshutdown
in interface EventBundlePipe
InterruptedException
Copyright © 2017 Nuxeo. All rights reserved.