com.espertech.esper.runtime.internal.dataflow.op.eventbussink

Class EventBusSinkOp

java.lang.Object

com.espertech.esper.runtime.internal.dataflow.op.eventbussink.EventBusSinkOp

All Implemented Interfaces:

com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

public class EventBusSinkOp
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

Constructor Summary

Constructors

Constructor and Description
EventBusSinkOp(EventBusSinkFactory factory, com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext, com.espertech.esper.common.client.dataflow.core.EPDataFlowEventCollector collector)

Method Summary

Modifier and Type	Method and Description
void	close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)
void	onInput(int port, Object data)
void	open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusSinkOp

public EventBusSinkOp(EventBusSinkFactory factory,
                      com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext,
                      com.espertech.esper.common.client.dataflow.core.EPDataFlowEventCollector collector)

Method Detail

onInput

public void onInput(int port,
                    Object data)

open

public void open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)

Specified by:

open in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

close

public void close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)

Specified by:

close in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle