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
- Since:
- 8.4
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected EventBundle
filterBundle
(EventBundle events) protected String
getName()
void
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
Do the actual push on the Busvoid
sendEventBundle
(EventBundle events) Send anEventBundle
inside the pipevoid
shutdown()
Shutdown callback when theEventService
stopsMethods 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
-
Field Details
-
name
-
params
-
-
Constructor Details
-
AbstractEventBundlePipe
public AbstractEventBundlePipe()
-
-
Method Details
-
initPipe
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
-
getParameters
-
sendEventBundle
Description copied from interface:EventBundlePipe
Send anEventBundle
inside the pipe- Specified by:
sendEventBundle
in interfaceEventBundlePipe
-
filterBundle
-
preProcessBundle
-
marshall
de-hydrate the EventBundle to make it suitable for transmission on a Bus -
send
Do the actual push on the Bus -
shutdown
Description copied from interface:EventBundlePipe
Shutdown callback when theEventService
stops- Specified by:
shutdown
in interfaceEventBundlePipe
- Throws:
InterruptedException
-