Uses of Interface
org.redisson.api.queue.QueuePollArgs

Packages that use QueuePollArgs

Package	Description
org.redisson.api
org.redisson.api.queue

Uses of QueuePollArgs in org.redisson.api

Methods in org.redisson.api with parameters of type QueuePollArgs

Modifier and Type	Method	Description
Message<V>	RReliableQueue.poll(QueuePollArgs args)	Retrieves and removes the head of this queue with the specified polling arguments.
reactor.core.publisher.Mono<Message<V>>	RReliableQueueReactive.poll(QueuePollArgs args)	Retrieves and removes the head of this queue with the specified polling arguments.
io.reactivex.rxjava3.core.Maybe<Message<V>>	RReliableQueueRx.poll(QueuePollArgs args)	Retrieves and removes the head of this queue with the specified polling arguments.
RFuture<Message<V>>	RReliableQueueAsync.pollAsync(QueuePollArgs args)	Retrieves and removes the head of this queue with the specified polling arguments.
List<Message<V>>	RReliableQueue.pollMany(QueuePollArgs pargs)	Retrieves and removes multiple messages from the queue with the specified polling arguments.
reactor.core.publisher.Mono<List<Message<V>>>	RReliableQueueReactive.pollMany(QueuePollArgs pargs)	Retrieves and removes multiple messages from the queue with the specified polling arguments.
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableQueueRx.pollMany(QueuePollArgs pargs)	Retrieves and removes multiple messages from the queue with the specified polling arguments.
RFuture<List<Message<V>>>	RReliableQueueAsync.pollManyAsync(QueuePollArgs pargs)	Retrieves and removes multiple messages from the queue with the specified polling arguments.

Uses of QueuePollArgs in org.redisson.api.queue

Classes in org.redisson.api.queue that implement QueuePollArgs

Modifier and Type	Class	Description
final class	QueuePollParams

Methods in org.redisson.api.queue that return QueuePollArgs

Modifier and Type	Method	Description
QueuePollArgs	QueuePollArgs.acknowledgeMode(AcknowledgeMode mode)	Sets the acknowledgment mode for message processing.
QueuePollArgs	QueuePollParams.acknowledgeMode(AcknowledgeMode mode)
QueuePollArgs	QueuePollArgs.count(int value)	Sets the maximum number of messages to retrieve in a single poll operation.
QueuePollArgs	QueuePollParams.count(int value)
static QueuePollArgs	QueuePollArgs.defaults()	Creates a new instance of QueuePollArgs with default settings.
QueuePollArgs	QueuePollArgs.headersCodec(Codec codec)	Specifies the codec to use for decoding message headers.
QueuePollArgs	QueuePollParams.headersCodec(Codec codec)
QueuePollArgs	QueuePollArgs.timeout(Duration value)	Sets the maximum time to wait for messages to become available.
QueuePollArgs	QueuePollParams.timeout(Duration timeout)
QueuePollArgs	QueuePollArgs.visibility(Duration value)	Sets the visibility timeout for retrieved messages.
QueuePollArgs	QueuePollParams.visibility(Duration visibility)