Package org.redisson.api.fanout
Interface MessageFilter<V>
- All Superinterfaces:
BiPredicate<V,,Map<String, Object>> Serializable
Interface for filtering messages in a ReliableFanout object.
Implementing this interface allows selective message delivery to subscribers based on custom logic. The filter evaluates messages and determines if they should be delivered to specific subscribers.
As a serializable BiPredicate, instances of this interface can be: - Transmitted across network boundaries - Replicated among all ReliableFanout objects - Applied on each node during message publishing process
When implemented, the test method should return true if the message should be delivered, or false to filter it out.
- Author:
- Nikita Koksharov
-
Method Summary
Methods inherited from interface java.util.function.BiPredicate
and, negate, or, test