Package 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	Description
AMQPSettingsSourceFactory()

Method Summary

Modifier and Type	Method	Description
AMQPSettingsSourceValues	evaluate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
Map<String,Object>	getCollector()
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator	getConsumeAutoAck()
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator	getPrefetchCount()
void	setCollector(Map<String,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 Details

AMQPSettingsSourceFactory

public AMQPSettingsSourceFactory()

Method Details

evaluate

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

getCollector

public Map<String,Object> getCollector()

setCollector

public void setCollector(Map<String,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)