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

Method Summary

Modifier and Type	Method	Description
Map	getCollector()
com.espertech.esper.common.internal.epl.expression.core.ExprNode	getConsumeAutoAck()
com.espertech.esper.common.internal.epl.expression.core.ExprNode	getPrefetchCount()
void	setCollector(Map<String,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 Details

AMQPSettingsSourceForge

public AMQPSettingsSourceForge()

Method Details

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 Map getCollector()

setCollector

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