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 Details

    • AMQPSourceFactory

      public AMQPSourceFactory()
  • Method Details

    • 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
    • setSettings

      public void setSettings(AMQPSettingsSourceFactory settings)
    • setOutputEventType

      public void setOutputEventType(com.espertech.esper.common.client.EventType outputEventType)