Package com.espertech.esper.runtime.internal.dataflow.op.epstatementsource

Class LocalEmitter

java.lang.Object

com.espertech.esper.runtime.internal.dataflow.op.epstatementsource.LocalEmitter

All Implemented Interfaces:

com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter

public class LocalEmitter
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter

Constructor Summary

Constructors

Constructor	Description
LocalEmitter(LinkedBlockingQueue<Object> queue)

Method Summary

Modifier and Type	Method	Description
void	submit(Object object)
void	submitPort(int portNumber, Object object)
void	submitSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal)

Methods inherited from class java.lang.Object

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

Constructor Details

LocalEmitter

public LocalEmitter(LinkedBlockingQueue<Object> queue)

Method Details

submit

public void submit(Object object)

Specified by:

submit in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter

submitSignal

public void submitSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal)

Specified by:

submitSignal in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter

submitPort

public void submitPort(int portNumber,
 Object object)

Specified by:

submitPort in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter