Package org.nuxeo.ecm.core.event.pipe
Interface EventBundlePipe
-
- All Known Implementing Classes:
AbstractEventBundlePipe
,LocalEventBundlePipe
public interface EventBundlePipe
Interface for a pipe of events. This is the abstraction used to bridge the Nuxeo events to pipes that consume them.- Since:
- 8.4
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
initPipe(String name, Map<String,String> params)
Initialize the Pipe when Nuxeo Event Service startsvoid
sendEventBundle(EventBundle events)
Send anEventBundle
inside the pipevoid
shutdown()
Shutdown callback when theEventService
stopsboolean
waitForCompletion(long timeoutMillis)
Wait until the end of event consumption
-
-
-
Method Detail
-
initPipe
void initPipe(String name, Map<String,String> params)
Initialize the Pipe when Nuxeo Event Service starts- Parameters:
name
- the name as defined in the XMap descriptorparams
- the parameters as defined in the XMap descriptor
-
sendEventBundle
void sendEventBundle(EventBundle events)
Send anEventBundle
inside the pipe
-
waitForCompletion
boolean waitForCompletion(long timeoutMillis) throws InterruptedException
Wait until the end of event consumption- Throws:
InterruptedException
-
shutdown
void shutdown() throws InterruptedException
Shutdown callback when theEventService
stops- Throws:
InterruptedException
-
-