com.espertech.esper.dataflow.ops
Class EPStatementSource.LocalEmitter

java.lang.Object
  com.espertech.esper.dataflow.ops.EPStatementSource.LocalEmitter

All Implemented Interfaces:

EPDataFlowEmitter

Enclosing class:

EPStatementSource

public static class EPStatementSource.LocalEmitter
extends java.lang.Object
implements EPDataFlowEmitter

Constructor Summary

EPStatementSource.LocalEmitter(java.util.concurrent.LinkedBlockingQueue<java.lang.Object> queue)

Method Summary

void	submit(java.lang.Object object)
void	submitPort(int portNumber, java.lang.Object object)
void	submitSignal(EPDataFlowSignal signal)

Methods inherited from class java.lang.Object

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

Constructor Detail

EPStatementSource.LocalEmitter

public EPStatementSource.LocalEmitter(java.util.concurrent.LinkedBlockingQueue<java.lang.Object> queue)

Method Detail

submit

public void submit(java.lang.Object object)

Specified by:

submit in interface EPDataFlowEmitter

submitSignal

public void submitSignal(EPDataFlowSignal signal)

Specified by:

submitSignal in interface EPDataFlowEmitter

submitPort

public void submitPort(int portNumber,
                       java.lang.Object object)

Specified by:

submitPort in interface EPDataFlowEmitter