Class QueueOptions

java.lang.Object
io.vertx.rabbitmq.QueueOptions
public class QueueOptions extends Object
Aimed to specify queue consumer settings when calling RabbitMQClient.basicConsumer(String, QueueOptions)

  • Constructor Details

    • QueueOptions

      public QueueOptions()

    • QueueOptions

      public QueueOptions(JsonObject json)

  • Method Details

    • setAutoAck

      public QueueOptions setAutoAck(boolean autoAck)
      Parameters:
      autoAck - true if the server should consider messages acknowledged once delivered; false if the server should expect explicit acknowledgements

    • setMaxInternalQueueSize

      public QueueOptions setMaxInternalQueueSize(int maxInternalQueueSize)
      Parameters:
      maxInternalQueueSize - the size of internal queue

    • isAutoAck

      public boolean isAutoAck()
      Returns:
      true if the server should consider messages acknowledged once delivered; false if the server should expect explicit acknowledgements

    • maxInternalQueueSize

      public int maxInternalQueueSize()
      Returns:
      the size of internal queue

    • isNoLocal

      public boolean isNoLocal()

    • setNoLocal

      public void setNoLocal(boolean noLocal)

    • isConsumerExclusive

      public boolean isConsumerExclusive()

    • setConsumerExclusive

      public void setConsumerExclusive(boolean consumerExclusive)

    • getConsumerTag

      public String getConsumerTag()

    • setConsumerTag

      public void setConsumerTag(String consumerTag)

    • getConsumerArguments

      public Map<String,Object> getConsumerArguments()

    • setConsumerArguments

      public void setConsumerArguments(Map<String,Object> consumerArguments)