Package com.espertech.esperio.amqp
Class AMQPSourceFactory
java.lang.Object
com.espertech.esperio.amqp.AMQPSourceFactory
- All Implemented Interfaces:
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
public class AMQPSourceFactory
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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
setOutputEventType
(com.espertech.esper.common.client.EventType outputEventType) void
setSettings
(AMQPSettingsSourceFactory settings)
-
Constructor Details
-
AMQPSourceFactory
public AMQPSourceFactory()
-
-
Method Details
-
initializeFactory
public void initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context) - Specified by:
initializeFactory
in interfacecom.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 interfacecom.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
-
setSettings
-
setOutputEventType
public void setOutputEventType(com.espertech.esper.common.client.EventType outputEventType)
-