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

Packages that use QueueAddArgs

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

Uses of QueueAddArgs in org.redisson.api

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

Modifier and Type	Method	Description
Message<V>	RReliableQueue.add(QueueAddArgs<V> params)	Adds a message to the queue with the specified parameters.
reactor.core.publisher.Mono<Message<V>>	RReliableQueueReactive.add(QueueAddArgs<V> params)	Adds a message to the queue with the specified parameters.
io.reactivex.rxjava3.core.Maybe<Message<V>>	RReliableQueueRx.add(QueueAddArgs<V> params)	Adds a message to the queue with the specified parameters.
RFuture<Message<V>>	RReliableQueueAsync.addAsync(QueueAddArgs<V> params)	Adds a message to the queue with the specified parameters.
List<Message<V>>	RReliableQueue.addMany(QueueAddArgs<V> params)	Adds multiple messages to the queue in a single operation.
reactor.core.publisher.Mono<List<Message<V>>>	RReliableQueueReactive.addMany(QueueAddArgs<V> params)	Adds multiple messages to the queue in a Mono operation.
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableQueueRx.addMany(QueueAddArgs<V> params)	Adds multiple messages to the queue in a single operation.
RFuture<List<Message<V>>>	RReliableQueueAsync.addManyAsync(QueueAddArgs<V> params)	Adds multiple messages to the queue in a single operation.

Uses of QueueAddArgs in org.redisson.api.queue

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

Modifier and Type	Class	Description
final class	QueueAddParams<V>

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

Modifier and Type	Method	Description
QueueAddArgs<V>	QueueAddArgs.headersCodec(Codec codec)	Sets the codec to be used for encoding and decoding message headers.
QueueAddArgs<V>	QueueAddParams.headersCodec(Codec codec)
static <V> QueueAddArgs<V>	QueueAddArgs.messages(MessageArgs<V>... msgs)	Defines messages to be added.
QueueAddArgs<V>	QueueAddArgs.timeout(Duration value)	Sets the maximum time to wait when adding messages to a full queue with a limited size.
QueueAddArgs<V>	QueueAddParams.timeout(Duration value)