Interface NodeSelectionPubSubReactiveCommands<K,V>
-
public interface NodeSelectionPubSubReactiveCommands<K,V>
Reactive executed commands on a node selection for Pub/Sub.- Since:
- 4.4
- Author:
- Mark Paluch
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ReactiveExecutions<Void>
psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.ReactiveExecutions<Void>
punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.ReactiveExecutions<Void>
subscribe(K... channels)
Listen for messages published to the given channels.ReactiveExecutions<Void>
unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
-
-
-
Method Detail
-
psubscribe
ReactiveExecutions<Void> psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.- Parameters:
patterns
- the patterns- Returns:
- RedisFuture<Void> Future to synchronize
psubscribe
completion
-
punsubscribe
ReactiveExecutions<Void> punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.- Parameters:
patterns
- the patterns- Returns:
- RedisFuture<Void> Future to synchronize
punsubscribe
completion
-
subscribe
ReactiveExecutions<Void> subscribe(K... channels)
Listen for messages published to the given channels.- Parameters:
channels
- the channels- Returns:
- RedisFuture<Void> Future to synchronize
subscribe
completion
-
unsubscribe
ReactiveExecutions<Void> unsubscribe(K... channels)
Stop listening for messages posted to the given channels.- Parameters:
channels
- the channels- Returns:
- RedisFuture<Void> Future to synchronize
unsubscribe
completion.
-
-