EventBundlePipe (Nuxeo 2021.70.4 API Documentation)

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 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

- 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 descriptor
    
    params - the parameters as defined in the XMap descriptor
  - sendEventBundle
```
void sendEventBundle(EventBundle events)
```
    Send an EventBundle 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 the EventService stops
    
    Throws:
    
    InterruptedException