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

Class EventBusSourceOp

java.lang.Object

com.espertech.esper.runtime.internal.dataflow.op.eventbussource.EventBusSourceOp

All Implemented Interfaces:

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

public class EventBusSourceOp
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowSourceOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle, com.espertech.esper.common.internal.filtersvc.FilterHandleCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected LinkedBlockingDeque<Object>	emittables
protected com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter	graphContext

Constructor Summary

Constructors

Constructor and Description
EventBusSourceOp(EventBusSourceFactory factory, com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext, com.espertech.esper.common.client.dataflow.core.EPDataFlowEventBeanCollector collector)

Method Summary

Modifier and Type	Method and Description
void	close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext closeContext)
boolean	isSubSelect()
void	matchFound(com.espertech.esper.common.client.EventBean theEvent, Collection<com.espertech.esper.common.internal.filtersvc.FilterHandleCallback> allStmtMatches)
void	next()
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

Field Detail

graphContext

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

emittables

protected LinkedBlockingDeque<Object> emittables

Constructor Detail

EventBusSourceOp

public EventBusSourceOp(EventBusSourceFactory factory,
                        com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext,
                        com.espertech.esper.common.client.dataflow.core.EPDataFlowEventBeanCollector collector)

Method Detail

next

public void next()
          throws InterruptedException

Specified by:

next in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowSourceOperator

Throws:

InterruptedException

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

matchFound

public void matchFound(com.espertech.esper.common.client.EventBean theEvent,
                       Collection<com.espertech.esper.common.internal.filtersvc.FilterHandleCallback> allStmtMatches)

Specified by:

matchFound in interface com.espertech.esper.common.internal.filtersvc.FilterHandleCallback

isSubSelect

public boolean isSubSelect()

Specified by:

isSubSelect in interface com.espertech.esper.common.internal.filtersvc.FilterHandleCallback

close

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

Specified by:

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