com.espertech.esper.dataflow.ops
Class EventBusSource

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

All Implemented Interfaces:

DataFlowOpLifecycle, DataFlowSourceOperator, FilterHandle, FilterHandleCallback

public class EventBusSource
extends java.lang.Object
implements DataFlowSourceOperator, DataFlowOpLifecycle, FilterHandleCallback

Constructor Summary

EventBusSource()

Method Summary

void	close(DataFlowOpCloseContext openContext)
java.lang.String	getStatementId() Returns the statement id.
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext context)
boolean	isSubSelect() Returns true if the filter applies to subselects.
void	matchFound(EventBean theEvent, java.util.Collection<FilterHandleCallback> allStmtMatches) Indicate that an event was evaluated by the FilterService which matches the filter specification FilterSpecCompiled associated with this callback.
void	next()
void	open(DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusSource

public EventBusSource()

Method Detail

initialize

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

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

java.lang.Exception

next

public void next()
          throws java.lang.InterruptedException

Specified by:

next in interface DataFlowSourceOperator

Throws:

java.lang.InterruptedException

matchFound

public void matchFound(EventBean theEvent,
                       java.util.Collection<FilterHandleCallback> allStmtMatches)

Description copied from interface: FilterHandleCallback

Indicate that an event was evaluated by the FilterService which matches the filter specification FilterSpecCompiled associated with this callback.

Specified by:

matchFound in interface FilterHandleCallback

Parameters:

theEvent - - the event received that matches the filter specification

isSubSelect

public boolean isSubSelect()

Description copied from interface: FilterHandleCallback

Returns true if the filter applies to subselects.

Specified by:

isSubSelect in interface FilterHandleCallback

Returns:

subselect filter

getStatementId

public java.lang.String getStatementId()

Description copied from interface: FilterHandle

Returns the statement id.

Specified by:

getStatementId in interface FilterHandle

Returns:

statement id

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle