Package com.espertech.esperio.amqp

Class AMQPSettingsFactoryBase

java.lang.Object
com.espertech.esperio.amqp.AMQPSettingsFactoryBase
Direct Known Subclasses:
AMQPSettingsSinkFactory, AMQPSettingsSourceFactory
public abstract class AMQPSettingsFactoryBase extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    AMQPSettingsFactoryBase()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    setDeclareAdditionalArgs(Map<String,Object> declareAdditionalArgs)
     
    void
    setDeclareAutoDelete(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator declareAutoDelete)
     
    void
    setDeclareDurable(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator declareDurable)
     
    void
    setDeclareExclusive(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator declareExclusive)
     
    void
    setExchange(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator exchange)
     
    void
    setHost(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator host)
     
    void
    setLogMessages(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator logMessages)
     
    void
    setPassword(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator password)
     
    void
    setPort(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator port)
     
    void
    setQueueName(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator queueName)
     
    void
    setRoutingKey(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator routingKey)
     
    void
    setUsername(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator username)
     
    void
    setVhost(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator vhost)
     
    void
    setWaitMSecNextMsg(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator waitMSecNextMsg)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AMQPSettingsFactoryBase

      public AMQPSettingsFactoryBase()

  • Method Details

    • setHost

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

    • setPort

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

    • setUsername

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

    • setPassword

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

    • setVhost

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

    • setQueueName

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

    • setExchange

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

    • setRoutingKey

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

    • setLogMessages

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

    • setWaitMSecNextMsg

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

    • setDeclareDurable

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

    • setDeclareExclusive

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

    • setDeclareAutoDelete

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

    • setDeclareAdditionalArgs

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