public class AMQPSourceFactory
extends java.lang.Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
Constructor and Description |
---|
AMQPSourceFactory() |
Modifier and Type | Method and Description |
---|---|
void |
initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context) |
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator |
operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context) |
void |
setSettings(AMQPSettingsSourceFactory settings) |
public void initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context)
initializeFactory
in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
public com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
operator
in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
public void setSettings(AMQPSettingsSourceFactory settings)