com.espertech.esper.dataflow.ops
Class EventBusSink

java.lang.Object
  com.espertech.esper.dataflow.ops.EventBusSink

All Implemented Interfaces:

DataFlowOpLifecycle

public class EventBusSink
extends java.lang.Object
implements DataFlowOpLifecycle

Constructor Summary

EventBusSink()

Method Summary

void	close(DataFlowOpCloseContext openContext)
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext context)
void	onInput(int port, java.lang.Object data)
void	open(DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventBusSink

public EventBusSink()

Method Detail

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws java.lang.Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

java.lang.Exception

onInput

public void onInput(int port,
                    java.lang.Object data)

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle