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

Packages that use MessageFilter

Package	Description
org.redisson.api

Uses of MessageFilter in org.redisson.api

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

Modifier and Type	Method	Description
void	RReliableFanout.setFilter(String name, MessageFilter<V> filter)	Sets a filter that is applied to all messages published to the queue through this fanout.
reactor.core.publisher.Mono<Void>	RReliableFanoutReactive.setFilter(String name, MessageFilter<V> filter)	Sets a filter that is applied to all messages published to the queue through this fanout.
io.reactivex.rxjava3.core.Completable	RReliableFanoutRx.setFilter(String name, MessageFilter<V> filter)	Sets a filter that is applied to all messages published to the queue through this fanout.
RFuture<Void>	RReliableFanoutAsync.setFilterAsync(String name, MessageFilter<V> filter)	Sets a filter that is applied to all messages published to the queue through this fanout.
boolean	RReliableFanout.subscribeQueue(String name, MessageFilter<V> filter)	Subscribes a queue with the specified name to this fanout with a filter.
reactor.core.publisher.Mono<Boolean>	RReliableFanoutReactive.subscribeQueue(String name, MessageFilter<V> filter)	Subscribes a queue with the specified name to this fanout with a filter.
io.reactivex.rxjava3.core.Single<Boolean>	RReliableFanoutRx.subscribeQueue(String name, MessageFilter<V> filter)	Subscribes a queue with the specified name to this fanout with a filter.
RFuture<Boolean>	RReliableFanoutAsync.subscribeQueueAsync(String name, MessageFilter<V> filter)	Subscribes a queue with the specified name to this fanout with a filter.