com.espertech.esperio.amqp

Class AMQPSettingsSourceFactory

java.lang.Object

com.espertech.esperio.amqp.AMQPSettingsFactoryBase

com.espertech.esperio.amqp.AMQPSettingsSourceFactory

public class AMQPSettingsSourceFactory
extends AMQPSettingsFactoryBase

Constructor Summary

Constructors

Constructor and Description
AMQPSettingsSourceFactory()

Method Summary

Modifier and Type	Method and Description
AMQPSettingsSourceValues	evaluate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
java.util.Map<java.lang.String,java.lang.Object>	getCollector()
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator	getConsumeAutoAck()
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator	getPrefetchCount()
void	setCollector(java.util.Map<java.lang.String,java.lang.Object> collector)
void	setConsumeAutoAck(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator consumeAutoAck)
void	setPrefetchCount(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator prefetchCount)

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, toString, wait, wait, wait

Constructor Detail

AMQPSettingsSourceFactory

public AMQPSettingsSourceFactory()

Method Detail

evaluate

public AMQPSettingsSourceValues 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)

getPrefetchCount

public com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator getPrefetchCount()

setPrefetchCount

public void setPrefetchCount(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator prefetchCount)

getConsumeAutoAck

public com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator getConsumeAutoAck()

setConsumeAutoAck

public void setConsumeAutoAck(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator consumeAutoAck)