Package 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 Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

Constructor Summary

Constructors

Constructor	Description
AMQPSinkFactory()

Method Summary

Modifier and Type	Method	Description
com.espertech.esper.common.client.EventType	getEventType()
static org.slf4j.Logger	getLog()
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	setEventType(com.espertech.esper.common.client.EventType eventType)
void	setSettings(AMQPSettingsSinkFactory settings)

Methods inherited from class java.lang.Object

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

Constructor Details

AMQPSinkFactory

public AMQPSinkFactory()

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

getSettings

public AMQPSettingsSinkFactory getSettings()

setSettings

public void setSettings(AMQPSettingsSinkFactory settings)

getLog

public static org.slf4j.Logger getLog()

getEventType

public com.espertech.esper.common.client.EventType getEventType()

setEventType

public void setEventType(com.espertech.esper.common.client.EventType eventType)