public abstract class AMQPSettingsForgeBase
extends java.lang.Object
Constructor and Description |
---|
AMQPSettingsForgeBase() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.lang.Object> |
getDeclareAdditionalArgs() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getDeclareAutoDelete() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getDeclareDurable() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getDeclareExclusive() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getExchange() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getHost() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getLogMessages() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getPassword() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getPort() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getQueueName() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getRoutingKey() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getUsername() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getVhost() |
com.espertech.esper.common.internal.epl.expression.core.ExprNode |
getWaitMSecNextMsg() |
void |
setDeclareAdditionalArgs(java.util.Map<java.lang.String,java.lang.Object> declareAdditionalArgs) |
void |
setDeclareAutoDelete(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareAutoDelete) |
void |
setDeclareDurable(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareDurable) |
void |
setDeclareExclusive(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareExclusive) |
void |
setExchange(com.espertech.esper.common.internal.epl.expression.core.ExprNode exchange) |
void |
setHost(com.espertech.esper.common.internal.epl.expression.core.ExprNode host) |
void |
setLogMessages(com.espertech.esper.common.internal.epl.expression.core.ExprNode logMessages) |
void |
setPassword(com.espertech.esper.common.internal.epl.expression.core.ExprNode password) |
void |
setPort(com.espertech.esper.common.internal.epl.expression.core.ExprNode port) |
void |
setQueueName(com.espertech.esper.common.internal.epl.expression.core.ExprNode queueName) |
void |
setRoutingKey(com.espertech.esper.common.internal.epl.expression.core.ExprNode routingKey) |
void |
setUsername(com.espertech.esper.common.internal.epl.expression.core.ExprNode username) |
void |
setVhost(com.espertech.esper.common.internal.epl.expression.core.ExprNode vhost) |
void |
setWaitMSecNextMsg(com.espertech.esper.common.internal.epl.expression.core.ExprNode waitMSecNextMsg) |
protected void |
validate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeContext context) |
protected void validate(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpForgeInitializeContext context) throws com.espertech.esper.common.internal.epl.expression.core.ExprValidationException
com.espertech.esper.common.internal.epl.expression.core.ExprValidationException
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getHost()
public void setHost(com.espertech.esper.common.internal.epl.expression.core.ExprNode host)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getPort()
public void setPort(com.espertech.esper.common.internal.epl.expression.core.ExprNode port)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getUsername()
public void setUsername(com.espertech.esper.common.internal.epl.expression.core.ExprNode username)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getPassword()
public void setPassword(com.espertech.esper.common.internal.epl.expression.core.ExprNode password)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getVhost()
public void setVhost(com.espertech.esper.common.internal.epl.expression.core.ExprNode vhost)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getQueueName()
public void setQueueName(com.espertech.esper.common.internal.epl.expression.core.ExprNode queueName)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getExchange()
public void setExchange(com.espertech.esper.common.internal.epl.expression.core.ExprNode exchange)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getRoutingKey()
public void setRoutingKey(com.espertech.esper.common.internal.epl.expression.core.ExprNode routingKey)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getLogMessages()
public void setLogMessages(com.espertech.esper.common.internal.epl.expression.core.ExprNode logMessages)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getWaitMSecNextMsg()
public void setWaitMSecNextMsg(com.espertech.esper.common.internal.epl.expression.core.ExprNode waitMSecNextMsg)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getDeclareDurable()
public void setDeclareDurable(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareDurable)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getDeclareExclusive()
public void setDeclareExclusive(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareExclusive)
public com.espertech.esper.common.internal.epl.expression.core.ExprNode getDeclareAutoDelete()
public void setDeclareAutoDelete(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareAutoDelete)
public java.util.Map<java.lang.String,java.lang.Object> getDeclareAdditionalArgs()
public void setDeclareAdditionalArgs(java.util.Map<java.lang.String,java.lang.Object> declareAdditionalArgs)