com.espertech.esperio.amqp

Class AMQPSinkFactory

java.lang.Object

com.espertech.esperio.amqp.AMQPSinkFactory

All Implemented Interfaces:

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

public class AMQPSinkFactory
extends java.lang.Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

Constructor Summary

Constructors

Constructor and Description
AMQPSinkFactory()

Method Summary

Modifier and Type	Method and Description
AMQPSettingsSinkFactory	getSettings()
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(AMQPSettingsSinkFactory settings)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPSinkFactory

public AMQPSinkFactory()

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

getSettings

public AMQPSettingsSinkFactory getSettings()

setSettings

public void setSettings(AMQPSettingsSinkFactory settings)