Interface Management

All Superinterfaces:

AutoCloseable

public interface Management
extends AutoCloseable

API to manage AMQ 0.9.1 model topology (exchanges, queues, and bindings).

See Also:

• AMQ 0.9.1 Model

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Management.BindingSpecification	Specification of a binding.
static interface	Management.ClassicQueueSpecification	Specification of a classic queue.
static enum	Management.ClassicQueueVersion	Classic queue version.
static interface	Management.ExchangeSpecification	Specification of an exchange.
static enum	Management.ExchangeType	Exchange type.
static enum	Management.OverflowStrategy	Overflow strategy (when a queue reaches its maximum length limit).
static interface	Management.PurgeStatus
static interface	Management.QueueInfo	Queue information.
static enum	Management.QueueLeaderLocator	Queue leader locator.
static interface	Management.QueueSpecification	Specification to create a queue.
static enum	Management.QueueType	Queue Type.
static enum	Management.QuorumQueueDeadLetterStrategy	Dead letter strategy for quorum queues.
static interface	Management.QuorumQueueSpecification	Specification of a quorum queue.
static interface	Management.StreamSpecification	Specification of a stream.
static interface	Management.UnbindSpecification	Unbind specification.

Method Summary

Modifier and Type	Method	Description
Management.BindingSpecification	binding()	Start binding specification.
void	close()	Close the management instance and release its resources.
Management.ExchangeSpecification	exchange()	Start exchange specification.
Management.ExchangeSpecification	exchange(String name)	Start exchange specification.
void	exchangeDelete(String name)	Delete an exchange.
Management.QueueSpecification	queue()	Start queue specification.
Management.QueueSpecification	queue(String name)	Start queue specification.
void	queueDelete(String name)	Delete a queue.
Management.QueueInfo	queueInfo(String name)	Query information on a queue.
Management.PurgeStatus	queuePurge(String queue)	Purge (delete all messages) from a queue.
Management.UnbindSpecification	unbind()	Start unbinding specification.

Method Details

queue

Management.QueueSpecification queue()

Start queue specification.

Returns:

the queue specification

queue

Management.QueueSpecification queue(String name)

Start queue specification.

Parameters:

name - the name of the queue

Returns:

the queue specification

queueInfo

Management.QueueInfo queueInfo(String name)

Query information on a queue.

Parameters:

name - the name of the queue

Returns:

the queue information

queueDelete

void queueDelete(String name)

Delete a queue.

Parameters:

name - the name of the queue

queuePurge

Management.PurgeStatus queuePurge(String queue)

Purge (delete all messages) from a queue.

Parameters:

queue - queue to delete messages from

Returns:

the status of the purge operation

exchange

Management.ExchangeSpecification exchange()

Start exchange specification.

Returns:

the exchange specification

exchange

Management.ExchangeSpecification exchange(String name)

Start exchange specification.

Parameters:

name - the name of the exchange

Returns:

the exchange specification

exchangeDelete

void exchangeDelete(String name)

Delete an exchange.

Parameters:

name - the name of the exchange

binding

Management.BindingSpecification binding()

Start binding specification.

Returns:

the binding definition

unbind

Management.UnbindSpecification unbind()

Start unbinding specification.

Returns:

the unbinding specification

close

void close()

Close the management instance and release its resources.

Specified by:

close in interface AutoCloseable