Package com.espertech.esperio.amqp

Class AMQPSettingsForgeBase

java.lang.Object
com.espertech.esperio.amqp.AMQPSettingsForgeBase
Direct Known Subclasses:
AMQPSettingsSinkForge, AMQPSettingsSourceForge
public abstract class AMQPSettingsForgeBase extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    AMQPSettingsForgeBase()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<String,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(Map<String,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)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • AMQPSettingsForgeBase

      public AMQPSettingsForgeBase()

  • Method Details

    • validate

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

    • getHost

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

    • setHost

      public void setHost(com.espertech.esper.common.internal.epl.expression.core.ExprNode host)

    • getPort

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

    • setPort

      public void setPort(com.espertech.esper.common.internal.epl.expression.core.ExprNode port)

    • getUsername

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

    • setUsername

      public void setUsername(com.espertech.esper.common.internal.epl.expression.core.ExprNode username)

    • getPassword

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

    • setPassword

      public void setPassword(com.espertech.esper.common.internal.epl.expression.core.ExprNode password)

    • getVhost

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

    • setVhost

      public void setVhost(com.espertech.esper.common.internal.epl.expression.core.ExprNode vhost)

    • getQueueName

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

    • setQueueName

      public void setQueueName(com.espertech.esper.common.internal.epl.expression.core.ExprNode queueName)

    • getExchange

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

    • setExchange

      public void setExchange(com.espertech.esper.common.internal.epl.expression.core.ExprNode exchange)

    • getRoutingKey

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

    • setRoutingKey

      public void setRoutingKey(com.espertech.esper.common.internal.epl.expression.core.ExprNode routingKey)

    • getLogMessages

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

    • setLogMessages

      public void setLogMessages(com.espertech.esper.common.internal.epl.expression.core.ExprNode logMessages)

    • getWaitMSecNextMsg

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

    • setWaitMSecNextMsg

      public void setWaitMSecNextMsg(com.espertech.esper.common.internal.epl.expression.core.ExprNode waitMSecNextMsg)

    • getDeclareDurable

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

    • setDeclareDurable

      public void setDeclareDurable(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareDurable)

    • getDeclareExclusive

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

    • setDeclareExclusive

      public void setDeclareExclusive(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareExclusive)

    • getDeclareAutoDelete

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

    • setDeclareAutoDelete

      public void setDeclareAutoDelete(com.espertech.esper.common.internal.epl.expression.core.ExprNode declareAutoDelete)

    • getDeclareAdditionalArgs

      public Map<String,Object> getDeclareAdditionalArgs()

    • setDeclareAdditionalArgs

      public void setDeclareAdditionalArgs(Map<String,Object> declareAdditionalArgs)