Package org.nuxeo.ecm.core.event.pipe
Class AbstractEventBundlePipe<T>
- java.lang.Object
-
- org.nuxeo.ecm.core.event.pipe.AbstractEventBundlePipe<T>
-
- All Implemented Interfaces:
EventBundlePipe
- Direct Known Subclasses:
LocalEventBundlePipe
public abstract class AbstractEventBundlePipe<T> extends Object implements EventBundlePipe
- Since:
- 8.4
-
-
Constructor Summary
Constructors Constructor Description AbstractEventBundlePipe()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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 startsprotected abstract T
marshall(EventBundle events)
de-hydrate the EventBundle to make it suitable for transmission on a Busprotected void
preProcessBundle(EventBundle events)
protected abstract void
send(T message)
Do the actual push on the Busvoid
sendEventBundle(EventBundle events)
Send anEventBundle
inside the pipevoid
shutdown()
Shutdown callback when theEventService
stops-
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
waitForCompletion
-
-
-
-
Method Detail
-
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 interfaceEventBundlePipe
- Parameters:
name
- the name as defined in the XMap descriptorparams
- the parameters as defined in the XMap descriptor
-
getName
protected String getName()
-
sendEventBundle
public void sendEventBundle(EventBundle events)
Description copied from interface:EventBundlePipe
Send anEventBundle
inside the pipe- Specified by:
sendEventBundle
in interfaceEventBundlePipe
-
filterBundle
protected EventBundle filterBundle(EventBundle events)
-
preProcessBundle
protected void preProcessBundle(EventBundle events)
-
marshall
protected abstract T marshall(EventBundle events)
de-hydrate the EventBundle to make it suitable for transmission on a Bus
-
send
protected abstract void send(T message)
Do the actual push on the Bus
-
shutdown
public void shutdown() throws InterruptedException
Description copied from interface:EventBundlePipe
Shutdown callback when theEventService
stops- Specified by:
shutdown
in interfaceEventBundlePipe
- Throws:
InterruptedException
-
-