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 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.