com.espertech.esperio.amqp

Class AMQPSettingsSourceForge

java.lang.Object

com.espertech.esperio.amqp.AMQPSettingsForgeBase

com.espertech.esperio.amqp.AMQPSettingsSourceForge

public class AMQPSettingsSourceForge
extends AMQPSettingsForgeBase

Constructor Summary

Constructors

Constructor and Description
AMQPSettingsSourceForge()

Method Summary

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

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

getDeclareAdditionalArgs, getDeclareAutoDelete, getDeclareDurable, getDeclareExclusive, getExchange, getHost, getLogMessages, getPassword, getPort, getQueueName, getRoutingKey, getUsername, getVhost, getWaitMSecNextMsg, 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

AMQPSettingsSourceForge

public AMQPSettingsSourceForge()

Method Detail

validate

public void validate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeContext context)
              throws com.espertech.esper.common.internal.epl.expression.core.ExprValidationException

Overrides:

validate in class AMQPSettingsForgeBase

Throws:

com.espertech.esper.common.internal.epl.expression.core.ExprValidationException

getCollector

public java.util.Map 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.ExprNode getPrefetchCount()

setPrefetchCount

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

getConsumeAutoAck

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

setConsumeAutoAck

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