Uses of Interface
org.redisson.api.queue.QueueConfig
Packages that use QueueConfig
-
Uses of QueueConfig in org.redisson.api
Methods in org.redisson.api with parameters of type QueueConfigModifier and TypeMethodDescriptionvoidRReliableQueue.setConfig(QueueConfig config) Sets the configuration for this reliable queue.reactor.core.publisher.Mono<Void> RReliableQueueReactive.setConfig(QueueConfig config) Sets the configuration for this reliable queue.io.reactivex.rxjava3.core.CompletableRReliableQueueRx.setConfig(QueueConfig config) Sets the configuration for this reliable queue.RReliableQueueAsync.setConfigAsync(QueueConfig config) Sets the configuration for this reliable queue.booleanRReliableQueue.setConfigIfAbsent(QueueConfig config) Attempts to set the configuration for this reliable queue.reactor.core.publisher.Mono<Boolean> RReliableQueueReactive.setConfigIfAbsent(QueueConfig config) Attempts to set the configuration for this reliable queue.io.reactivex.rxjava3.core.Single<Boolean> RReliableQueueRx.setConfigIfAbsent(QueueConfig config) Attempts to set the configuration for this reliable queue.RReliableQueueAsync.setConfigIfAbsentAsync(QueueConfig config) Attempts to set the configuration for this reliable queue. -
Uses of QueueConfig in org.redisson.api.queue
Classes in org.redisson.api.queue that implement QueueConfigMethods in org.redisson.api.queue that return QueueConfigModifier and TypeMethodDescriptionQueueConfig.deadLetterQueueName(String value) Sets the name of the Dead Letter Queue (DLQ) to which messages that have reached the delivery limit or have been rejected are sent.QueueConfigParams.deadLetterQueueName(String value) static QueueConfigQueueConfig.defaults()Creates a new QueueConfig instance with default settings.Sets the delay duration before a message becomes available for consumption after being added to the queue. 0 value means delay duration is not applied.QueueConfig.deliveryLimit(int value) Defines the maximum number of delivery attempts for a message.QueueConfigParams.deliveryLimit(int value) QueueConfig.maxMessageSize(int value) Sets the maximum allowed size (in bytes) for a single message in the queue.QueueConfigParams.maxMessageSize(int value) QueueConfig.maxSize(int value) Sets the maximum number of messages that can be stored in the queue.QueueConfigParams.maxSize(int value) QueueConfig.processingMode(ProcessingMode mode) Sets the processing mode for the queue which determines how messages are processed by consumers.QueueConfigParams.processingMode(ProcessingMode mode) QueueConfig.timeToLive(Duration value) Sets the time-to-live duration for messages in the queue.QueueConfigParams.timeToLive(Duration value) QueueConfig.visibility(Duration value) Sets the duration for which a message becomes invisible to other consumers after being polled.QueueConfigParams.visibility(Duration value)