Interface Management.QuorumQueueSpecification

Enclosing interface:

Management

public static interface Management.QuorumQueueSpecification

Specification of a quorum queue.

See Also:

• Quorum Queues

Method Summary

Modifier and Type	Method	Description
Management.QuorumQueueSpecification	deadLetterStrategy(Management.QuorumQueueDeadLetterStrategy strategy)	The dead letter strategy.
Management.QuorumQueueSpecification	deadLetterStrategy(String strategy)	The dead letter strategy (as a string).
Management.QuorumQueueSpecification	delayedRetryMax(Duration max)	Set the maximum delay for delayed retry.
Management.QuorumQueueSpecification	delayedRetryMin(Duration min)	Set the minimum delay for delayed retry.
Management.QuorumQueueSpecification	delayedRetryType(Management.DelayedRetryType type)	Set the delayed retry type.
Management.QuorumQueueSpecification	deliveryLimit(int limit)	Set the delivery limit (for poison message handling).
Management.QuorumQueueSpecification	initialMemberCount(int initialMemberCount)	Set the number of initial members the quorum queue should have.
Management.QueueSpecification	queue()	Go back to the queue specification.

Method Details

deadLetterStrategy

Management.QuorumQueueSpecification deadLetterStrategy(String strategy)

The dead letter strategy (as a string).

Parameters:

strategy - dead letter strategy

Returns:

quorum queue specification

See Also:

• Quorum Queue Dead Lettering

deadLetterStrategy

Management.QuorumQueueSpecification deadLetterStrategy(Management.QuorumQueueDeadLetterStrategy strategy)

The dead letter strategy.

Parameters:

strategy - dead letter strategy

Returns:

quorum queue specification

See Also:

• Quorum Queue Dead Lettering

deliveryLimit

Management.QuorumQueueSpecification deliveryLimit(int limit)

Set the delivery limit (for poison message handling).

Parameters:

limit - delivery limit

Returns:

quorum queue specification

See Also:

• Poison Message Handling

initialMemberCount

Management.QuorumQueueSpecification initialMemberCount(int initialMemberCount)

Set the number of initial members the quorum queue should have.

Parameters:

initialMemberCount - initial number of nodes

Returns:

quorum queue specification

See Also:

• Initial Replication Factor

delayedRetryType

Management.QuorumQueueSpecification delayedRetryType(Management.DelayedRetryType type)

Set the delayed retry type.

Defines the conditions for delaying a message when it is returned to the queue.

The delay is calculated with linear back-off based on the message's delivery count: min(min_delay * delivery_count, max_delay). A per-message explicit delivery time can also be set by adding the x-opt-delivery-time annotation (a Unix timestamp in milliseconds) when requeuing a message with annotations (with Consumer.Context.discard(java.util.Map).

You must use delayedRetryMin(java.time.Duration) to set up the minimum retry delay.

Delayed retry support for quorum queues is available as of RabbitMQ 4.3.

Parameters:

type - delayed retry type

Returns:

quorum queue specification

See Also:

• Delayed Retry
• Delivery Count
• delayedRetryMin(java.time.Duration)

delayedRetryMin

Management.QuorumQueueSpecification delayedRetryMin(Duration min)

Set the minimum delay for delayed retry.

Parameters:

min - minimum delay

Returns:

quorum queue specification

See Also:

• delayedRetryType(DelayedRetryType)
• Delayed Retry

delayedRetryMax

Management.QuorumQueueSpecification delayedRetryMax(Duration max)

Set the maximum delay for delayed retry.

Parameters:

max - maximum delay

Returns:

quorum queue specification

See Also:

• delayedRetryType(DelayedRetryType)
• Delayed Retry

queue

Management.QueueSpecification queue()

Go back to the queue specification.

Returns:

queue specification