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	consumerTimeout(Duration timeout)	Set the consumer timeout for the quorum queue.
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

consumerTimeout

Management.QuorumQueueSpecification consumerTimeout(Duration timeout)

Set the consumer timeout for the quorum queue.

Quorum queues support configurable consumer timeouts to handle slow or stuck consumers. When a consumer holds unacknowledged messages beyond the configured timeout period, the messages are automatically returned to the queue and become available for redelivery by another consumer.

When a consumer timeout fires, for AMQP 1.0 clients, the broker sends a DISPOSITION frame with state=released instead of detaching the link. This allows the client to auto-settle the delivery and potentially recover without needing to re-establish the link. Until the consumer settles the timed out message it will not be assigned any further messages.

Parameters:

timeout - the consumer timeout duration

Returns:

quorum queue specification

See Also:

• Consumer Timeout

queue

Management.QueueSpecification queue()

Go back to the queue specification.

Returns:

queue specification