Uses of Class
org.springframework.amqp.core.QueueBuilder
Package
Description
Provides core classes for the spring AMQP abstraction.
-
Uses of QueueBuilder in org.springframework.amqp.core
Modifier and TypeMethodDescriptionQueueBuilder.autoDelete()
The final queue will auto delete.QueueBuilder.deadLetterExchange
(String dlx) Set the dead-letter exchange to which to route expired or rejected messages.QueueBuilder.deadLetterRoutingKey
(String dlrk) Set the routing key to use when routing expired or rejected messages to the dead-letter exchange.QueueBuilder.deliveryLimit
(int limit) Set the delivery limit; only applies to quorum queues.static QueueBuilder
QueueBuilder.durable()
Creates a builder for a durable queue with a generated unique name -spring.gen-<random>
.static QueueBuilder
Creates a builder for a durable queue.QueueBuilder.exclusive()
The final queue will be exclusive.QueueBuilder.expires
(int expires) Set the time that the queue can remain unused before being deleted.QueueBuilder.lazy()
Set the queue into lazy mode, keeping as many messages as possible on disk to reduce RAM usage on the broker.QueueBuilder.leaderLocator
(QueueBuilder.LeaderLocator locator) Set the master locator mode which determines which node a queue master will be located on a cluster of nodes.QueueBuilder.maxLength
(long count) Set the number of (ready) messages allowed in the queue before it starts to drop them.QueueBuilder.maxLengthBytes
(int bytes) Set the total aggregate body size allowed in the queue before it starts to drop them.QueueBuilder.maxPriority
(int maxPriority) Set the maximum number if priority levels for the queue to support; if not set, the queue will not support message priorities.static QueueBuilder
QueueBuilder.nonDurable()
Creates a builder for a non-durable (transient) queue.static QueueBuilder
QueueBuilder.nonDurable
(String name) Creates a builder for a non-durable (transient) queue.QueueBuilder.overflow
(QueueBuilder.Overflow overflow) Set the overflow mode when messages are dropped due to max messages or max message size is exceeded.QueueBuilder.quorum()
Set the queue argument to declare a queue of type 'quorum' instead of 'classic'.QueueBuilder.singleActiveConsumer()
Set the 'x-single-active-consumer' queue argument.QueueBuilder.stream()
Set the queue argument to declare a queue of type 'stream' instead of 'classic'.QueueBuilder.ttl
(int ttl) Set the message time-to-live after which it will be discarded, or routed to the dead-letter-exchange, if so configured.QueueBuilder.withArgument
(String key, Object value) The final queue will contain argument used to declare a queue.QueueBuilder.withArguments
(Map<String, Object> arguments) The final queue will contain arguments used to declare a queue.