com.espertech.esperio.amqp

Class AMQPSettingsSinkFactory

java.lang.Object

com.espertech.esperio.amqp.AMQPSettingsFactoryBase

com.espertech.esperio.amqp.AMQPSettingsSinkFactory

public class AMQPSettingsSinkFactory
extends AMQPSettingsFactoryBase

Constructor Summary

Constructors

Constructor and Description
AMQPSettingsSinkFactory()

Method Summary

Modifier and Type	Method and Description
AMQPSettingsSinkValues	evaluate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
java.util.Map<java.lang.String,java.lang.Object>	getCollector()
void	setCollector(java.util.Map<java.lang.String,java.lang.Object> collector)
java.lang.String	toString()

Methods inherited from class com.espertech.esperio.amqp.AMQPSettingsFactoryBase

setDeclareAdditionalArgs, setDeclareAutoDelete, setDeclareDurable, setDeclareExclusive, setExchange, setHost, setLogMessages, setPassword, setPort, setQueueName, setRoutingKey, setUsername, setVhost, setWaitMSecNextMsg

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPSettingsSinkFactory

public AMQPSettingsSinkFactory()

Method Detail

evaluate

public AMQPSettingsSinkValues evaluate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)

getCollector

public java.util.Map<java.lang.String,java.lang.Object> getCollector()

setCollector

public void setCollector(java.util.Map<java.lang.String,java.lang.Object> collector)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object