Uses of Interface
org.redisson.api.fanout.MessageFilter
Packages that use MessageFilter
-
Uses of MessageFilter in org.redisson.api
Methods in org.redisson.api with parameters of type MessageFilterModifier and TypeMethodDescriptionvoidRReliableFanout.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.CompletableRReliableFanoutRx.setFilter(String name, MessageFilter<V> filter) Sets a filter that is applied to all messages published to the queue through this fanout.RReliableFanoutAsync.setFilterAsync(String name, MessageFilter<V> filter) Sets a filter that is applied to all messages published to the queue through this fanout.booleanRReliableFanout.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.RReliableFanoutAsync.subscribeQueueAsync(String name, MessageFilter<V> filter) Subscribes a queue with the specified name to this fanout with a filter.