org.springframework.amqp.core

Class Queue

java.lang.Object

org.springframework.amqp.core.AbstractDeclarable

org.springframework.amqp.core.Queue

All Implemented Interfaces:

Declarable

Direct Known Subclasses:

AnonymousQueue

public class Queue
extends AbstractDeclarable

Simple container collecting information to describe a queue. Used in conjunction with AmqpAdmin.

Author:

Mark Pollack, Gary Russell

See Also:

AmqpAdmin

Field Summary

Fields

Modifier and Type	Field and Description
static String	X_QUEUE_MASTER_LOCATOR Argument key for the master locator.

Constructor Summary

Constructors

Constructor and Description
Queue(String name) The queue is durable, non-exclusive and non auto-delete.
Queue(String name, boolean durable) Construct a new queue, given a name and durability flag.
Queue(String name, boolean durable, boolean exclusive, boolean autoDelete) Construct a new queue, given a name, durability, exclusive and auto-delete flags.
Queue(String name, boolean durable, boolean exclusive, boolean autoDelete, Map<String,Object> arguments) Construct a new queue, given a name, durability flag, and auto-delete flag, and arguments.

Method Summary

Modifier and Type	Method and Description
String	getActualName() Return the name provided to the constructor or the broker-generated name if that name is an empty String.
Map<String,Object>	getArguments()
String	getName() Return the name provided in the constructor.
boolean	isAutoDelete() True if the server should delete the queue when it is no longer in use (the last consumer is cancelled).
boolean	isDurable() A durable queue will survive a server restart.
boolean	isExclusive() True if the server should only send messages to the declarer's connection.
void	setActualName(String name) Set the name from the DeclareOk.
void	setMasterLocator(String locator) Set the master locator strategy argument for this queue.
String	toString()

Methods inherited from class org.springframework.amqp.core.AbstractDeclarable

getDeclaringAdmins, isIgnoreDeclarationExceptions, setAdminsThatShouldDeclare, setIgnoreDeclarationExceptions, setShouldDeclare, shouldDeclare

Methods inherited from class java.lang.Object

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

Field Detail

X_QUEUE_MASTER_LOCATOR

public static final String X_QUEUE_MASTER_LOCATOR

Argument key for the master locator.

Since:

2.1

See Also:

Constant Field Values

Constructor Detail

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,
             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 Detail

getName

public String getName()

Return the name provided in the constructor.

Returns:

the name.

See Also:

getActualName()

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.

getArguments

public Map<String,Object> getArguments()

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

public final void setMasterLocator(@Nullable
                                   String locator)

Set the master locator strategy argument for this queue.

Parameters:

locator - the locator; null to clear the argument.

Since:

2.1

toString

public String toString()

Overrides:

toString in class Object