Interface IDelayedQueueSpecification
Optional arguments for delayed queues (x-queue-type: delayed).
Delayed queues are only available on Tanzu RabbitMQ 4.x or later.
public interface IDelayedQueueSpecification
Methods
DeadLetterStrategy(QuorumQueueDeadLetterStrategy)
IDelayedQueueSpecification DeadLetterStrategy(QuorumQueueDeadLetterStrategy strategy)
Parameters
strategyQuorumQueueDeadLetterStrategy
Returns
DeliveryLimit(int)
IDelayedQueueSpecification DeliveryLimit(int limit)
Parameters
limitint
Returns
Queue()
IQueueSpecification Queue()
Returns
QuorumInitialGroupSize(int)
IDelayedQueueSpecification QuorumInitialGroupSize(int size)
Parameters
sizeint
Returns
QuorumTargetGroupSize(int)
IDelayedQueueSpecification QuorumTargetGroupSize(int size)
Parameters
sizeint
Returns
ShovelAcknowledgement(string)
Sets the acknowledgement mode used by the shovel (x-shovel-ack-mode).
IDelayedQueueSpecification ShovelAcknowledgement(string ackMode)
Parameters
ackModestring
Returns
ShovelDestination(string)
Sets the destination queue for the automatic shovel (x-shovel-destination).
Setting this applies default values for the remaining shovel arguments, which can be
overridden by calling the other Shovel* methods afterwards.
IDelayedQueueSpecification ShovelDestination(string destinationQueue)
Parameters
destinationQueuestring
Returns
ShovelDestinationRoutingKey(string)
Sets the routing key used by the shovel when forwarding messages (x-shovel-destination-key).
IDelayedQueueSpecification ShovelDestinationRoutingKey(string routingKey)
Parameters
routingKeystring
Returns
ShovelDestinationUri(string)
Sets the AMQP URI of the broker the shovel forwards messages to (x-shovel-destination-uri).
IDelayedQueueSpecification ShovelDestinationUri(string uri)
Parameters
uristring
Returns
ShovelPrefetch(int)
Sets the number of messages the shovel fetches per round-trip (x-shovel-prefetch-count).
IDelayedQueueSpecification ShovelPrefetch(int prefetch)
Parameters
prefetchint
Returns
ShovelProtocol(string)
Sets the messaging protocol used by the shovel (x-shovel-protocol).
IDelayedQueueSpecification ShovelProtocol(string protocol)
Parameters
protocolstring