public interface EventBundlePipe
Modifier and Type | Method and Description |
---|---|
void |
initPipe(String name,
Map<String,String> params)
Initialize the Pipe when Nuxeo Event Service starts
|
void |
sendEventBundle(EventBundle events)
Send an
EventBundle inside the pipe |
void |
shutdown()
Shutdown callback when the
EventService stops |
boolean |
waitForCompletion(long timeoutMillis)
Wait until the end of event consumption
|
void initPipe(String name, Map<String,String> params)
name
- the name as defined in the XMap descriptorparams
- the parameters as defined in the XMap descriptorvoid sendEventBundle(EventBundle events)
EventBundle
inside the pipeevents
- boolean waitForCompletion(long timeoutMillis) throws InterruptedException
timeoutMillis
- InterruptedException
void shutdown() throws InterruptedException
EventService
stopsInterruptedException
Copyright © 2016 Nuxeo SA. All rights reserved.