Uses of Interface
org.redisson.api.fanout.FanoutPublishArgs

Packages that use FanoutPublishArgs

Package	Description
org.redisson.api
org.redisson.api.fanout

Uses of FanoutPublishArgs in org.redisson.api

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

Modifier and Type	Method	Description
Message<V>	RReliableFanout.publish(FanoutPublishArgs<V> args)	Publishes a message to all subscribed queues based on the provided 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.

Uses of FanoutPublishArgs in org.redisson.api.fanout

Classes in org.redisson.api.fanout that implement FanoutPublishArgs

Modifier and Type	Class	Description
final class	FanoutPublishParams<V>

Methods in org.redisson.api.fanout that return FanoutPublishArgs

Modifier and Type	Method	Description
FanoutPublishArgs<V>	FanoutPublishArgs.headersCodec(Codec codec)	Sets the codec to be used for encoding and decoding message headers.
FanoutPublishArgs<V>	FanoutPublishParams.headersCodec(Codec codec)
static <V> FanoutPublishArgs<V>	FanoutPublishArgs.messages(MessageArgs<V>... msgs)	Defines messages to be added.