Class Queue

All Implemented Interfaces:
Cloneable, Declarable
Direct Known Subclasses:
AnonymousQueue

public class Queue extends AbstractDeclarable implements Cloneable
Simple container collecting information to describe a queue. Used in conjunction with AmqpAdmin.
Author:
Mark Pollack, Gary Russell
See Also:
  • Field Details

  • Constructor Details

    • Queue

      public Queue(String name)
      The queue is durable, non-exclusive and non auto-delete.
      Parameters:
      name - the name of the queue.
    • Queue

      public Queue(String name, boolean durable)
      Construct a new queue, given a name and durability flag. The queue is non-exclusive and non auto-delete.
      Parameters:
      name - the name of the queue.
      durable - true if we are declaring a durable queue (the queue will survive a server restart)
    • Queue

      public Queue(String name, boolean durable, boolean exclusive, boolean autoDelete)
      Construct a new queue, given a name, durability, exclusive and auto-delete flags.
      Parameters:
      name - the name of the queue.
      durable - true if we are declaring a durable queue (the queue will survive a server restart)
      exclusive - true if we are declaring an exclusive queue (the queue will only be used by the declarer's connection)
      autoDelete - true if the server should delete the queue when it is no longer in use
    • Queue

      public Queue(String name, boolean durable, boolean exclusive, boolean autoDelete, @Nullable Map<String,Object> arguments)
      Construct a new queue, given a name, durability flag, and auto-delete flag, and arguments.
      Parameters:
      name - the name of the queue - must not be null; set to "" to have the broker generate the name.
      durable - true if we are declaring a durable queue (the queue will survive a server restart)
      exclusive - true if we are declaring an exclusive queue (the queue will only be used by the declarer's connection)
      autoDelete - true if the server should delete the queue when it is no longer in use
      arguments - the arguments used to declare the queue
  • Method Details

    • getName

      public String getName()
      Return the name provided in the constructor.
      Returns:
      the name.
      See Also:
    • isDurable

      public boolean isDurable()
      A durable queue will survive a server restart.
      Returns:
      true if durable.
    • isExclusive

      public boolean isExclusive()
      True if the server should only send messages to the declarer's connection.
      Returns:
      true if exclusive.
    • isAutoDelete

      public boolean isAutoDelete()
      True if the server should delete the queue when it is no longer in use (the last consumer is cancelled). A queue that never has any consumers will not be deleted automatically.
      Returns:
      true if auto-delete.
    • setActualName

      public void setActualName(String name)
      Set the name from the DeclareOk.
      Parameters:
      name - the name.
      Since:
      2.1
    • getActualName

      public String getActualName()
      Return the name provided to the constructor or the broker-generated name if that name is an empty String.
      Returns:
      the name.
      Since:
      2.1
    • setMasterLocator

      @Deprecated public final void setMasterLocator(@Nullable String locator)
      Deprecated.
      Set the master locator strategy argument for this queue.
      Parameters:
      locator - the locator; null to clear the argument.
      Since:
      2.1
    • setLeaderLocator

      public final void setLeaderLocator(@Nullable String locator)
      Set the leader locator strategy argument for this queue.
      Parameters:
      locator - the locator; null to clear the argument.
      Since:
      2.3.7
    • clone

      public Object clone()
      Overrides:
      clone in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object