EventBusSink (Esper API Documentation)

public class EventBusSink
extends Object
implements DataFlowOpLifecycle

Constructors
Constructor and Description
`EventBusSink()`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close(DataFlowOpCloseContext openContext)`
`DataFlowOpInitializeResult`	`initialize(DataFlowOpInitializateContext context)`
`void`	`onInput(int port, Object data)`
`void`	`open(DataFlowOpOpenContext openContext)`

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws Exception

public void onInput(int port,
                    Object data)

public void open(DataFlowOpOpenContext openContext)

public void close(DataFlowOpCloseContext openContext)

Class EventBusSink