Uses of Class
org.redisson.api.Message

Packages that use Message

Package	Description
org.redisson.api

Uses of Message in org.redisson.api

Methods in org.redisson.api that return Message

Modifier and Type	Method	Description
Message<V>	RReliableQueue.add(QueueAddArgs<V> params)	Adds a message to the queue with the specified parameters.
Message<V>	RReliableQueue.get(String id)	Returns message by id
Message<V>	RReliableQueue.get(Codec headersCodec, String id)	Returns message by id applying specified codec to headers
Message<V>	RReliableQueue.poll()	Retrieves and removes the head of this queue, or returns null if this queue is empty.
Message<V>	RReliableQueue.poll(QueuePollArgs args)	Retrieves and removes the head of this queue with the specified polling arguments.
Message<V>	RReliableFanout.publish(FanoutPublishArgs<V> args)	Publishes a message to all subscribed queues based on the provided arguments.

Methods in org.redisson.api that return types with arguments of type Message

Modifier and Type	Method	Description
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.
reactor.core.publisher.Mono<Message<V>>	RReliableQueueReactive.get(String id)	Returns message by id
reactor.core.publisher.Mono<Message<V>>	RReliableQueueReactive.get(Codec headersCodec, String id)	Returns message by id applying specified codec to headers
io.reactivex.rxjava3.core.Maybe<Message<V>>	RReliableQueueRx.get(String id)	Returns message by id
io.reactivex.rxjava3.core.Maybe<Message<V>>	RReliableQueueRx.get(Codec headersCodec, String id)	Returns message by id applying specified codec to headers
List<Message<V>>	RReliableQueue.getAll(String... ids)	Returns messages by ids
List<Message<V>>	RReliableQueue.getAll(Codec headersCodec, String... ids)	Returns messages by ids applying specified codec to headers
reactor.core.publisher.Mono<List<Message<V>>>	RReliableQueueReactive.getAll(String... ids)	Returns messages by ids
reactor.core.publisher.Mono<List<Message<V>>>	RReliableQueueReactive.getAll(Codec headersCodec, String... ids)	Returns messages by ids applying specified codec to headers
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableQueueRx.getAll(String... ids)	Returns messages by ids
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableQueueRx.getAll(Codec headersCodec, String... ids)	Returns messages by ids applying specified codec to headers
RFuture<List<Message<V>>>	RReliableQueueAsync.getAllAsync(String... ids)	Returns messages by ids
RFuture<List<Message<V>>>	RReliableQueueAsync.getAllAsync(Codec headersCodec, String... ids)	Returns messages by ids applying specified codec to headers
RFuture<Message<V>>	RReliableQueueAsync.getAsync(String id)	Returns message by id
RFuture<Message<V>>	RReliableQueueAsync.getAsync(Codec headersCodec, String id)	Returns message by id applying specified codec to headers
List<Message<V>>	RReliableQueue.listAll()	Returns all messages in the queue, ready to be retrieved by the poll() command, without removing them.
List<Message<V>>	RReliableQueue.listAll(Codec headersCodec)	Returns all messages in the queue, ready to be retrieved by the poll() command, using the specified codec for message header values.
reactor.core.publisher.Mono<List<Message<V>>>	RReliableQueueReactive.listAll()	Returns all messages in the queue, ready to be retrieved by the poll() command, without removing them.
reactor.core.publisher.Mono<List<Message<V>>>	RReliableQueueReactive.listAll(Codec headersCodec)	Returns all messages in the queue, ready to be retrieved by the poll() command, using the specified codec for message header values.
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableQueueRx.listAll()	Returns all messages in the queue, ready to be retrieved by the poll() command, without removing them.
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableQueueRx.listAll(Codec headersCodec)	Returns all messages in the queue, ready to be retrieved by the poll() command, using the specified codec for message header values.
RFuture<List<Message<V>>>	RReliableQueueAsync.listAllAsync()	Returns all messages in the queue, ready to be retrieved by the poll() command, without removing them.
RFuture<List<Message<V>>>	RReliableQueueAsync.listAllAsync(Codec headersCodec)	Returns all messages in the queue, ready to be retrieved by the poll() command, using the specified codec for message header values.
reactor.core.publisher.Mono<Message<V>>	RReliableQueueReactive.poll()	Retrieves and removes the head of this queue, or returns null if this queue is empty.
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()	Retrieves and removes the head of this queue, or returns null if this queue is empty.
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()	Retrieves and removes the head of this queue, or returns null if this queue is empty.
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.
reactor.core.publisher.Mono<Message<V>>	RReliableFanoutReactive.publish(FanoutPublishArgs<V> args)	Publishes a message to all subscribed queues based on the provided arguments.
io.reactivex.rxjava3.core.Maybe<Message<V>>	RReliableFanoutRx.publish(FanoutPublishArgs<V> args)	Publishes a message to all subscribed queues based on the provided arguments.
RFuture<Message<V>>	RReliableFanoutAsync.publishAsync(FanoutPublishArgs<V> args)	Publishes a message to all subscribed queues based on the provided arguments.
List<Message<V>>	RReliableFanout.publishMany(FanoutPublishArgs<V> args)	Publishes multiple messages to all subscribed queues based on the provided arguments.
reactor.core.publisher.Mono<List<Message<V>>>	RReliableFanoutReactive.publishMany(FanoutPublishArgs<V> args)	Publishes multiple messages to all subscribed queues based on the provided arguments.
io.reactivex.rxjava3.core.Single<List<Message<V>>>	RReliableFanoutRx.publishMany(FanoutPublishArgs<V> args)	Publishes multiple messages to all subscribed queues based on the provided arguments.
RFuture<List<Message<V>>>	RReliableFanoutAsync.publishManyAsync(FanoutPublishArgs<V> args)	Publishes multiple messages to all subscribed queues based on the provided arguments.