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

Class EventBusSourceFactory

java.lang.Object

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

All Implemented Interfaces:

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

public class EventBusSourceFactory
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

Constructor Summary

Constructors

Constructor and Description
EventBusSourceFactory()

Method Summary

Modifier and Type	Method and Description
com.espertech.esper.common.internal.filterspec.FilterSpecActivatable	getFilterSpecActivatable()
void	initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context)
boolean	isSubmitEventBean()
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator	operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
void	setCollector(Map<String,Object> collector)
void	setFilterSpecActivatable(com.espertech.esper.common.internal.filterspec.FilterSpecActivatable filterSpecActivatable)
void	setSubmitEventBean(boolean submitEventBean)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusSourceFactory

public EventBusSourceFactory()

Method Detail

initializeFactory

public void initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context)

Specified by:

initializeFactory in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

operator

public com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)

Specified by:

operator in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

setSubmitEventBean

public void setSubmitEventBean(boolean submitEventBean)

isSubmitEventBean

public boolean isSubmitEventBean()

setCollector

public void setCollector(Map<String,Object> collector)

getFilterSpecActivatable

public com.espertech.esper.common.internal.filterspec.FilterSpecActivatable getFilterSpecActivatable()

setFilterSpecActivatable

public void setFilterSpecActivatable(com.espertech.esper.common.internal.filterspec.FilterSpecActivatable filterSpecActivatable)