Class LettuceSubscription

java.lang.Object
org.springframework.data.redis.connection.util.AbstractSubscription
org.springframework.data.redis.connection.lettuce.LettuceSubscription
All Implemented Interfaces:
Subscription

public class LettuceSubscription extends AbstractSubscription
Message subscription on top of Lettuce.
Author:
Costin Leau, Mark Paluch, Christoph Strobl, Sarah Abbey, Murtuza Boxwala, Jens Deppe
  • Constructor Details

  • Method Details

    • getNativeConnection

      protected io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> getNativeConnection()
    • doClose

      protected void doClose()
      Description copied from class: AbstractSubscription
      Shutdown the subscription and free any resources held.
      Specified by:
      doClose in class AbstractSubscription
    • doPsubscribe

      protected void doPsubscribe(byte[]... patterns)
      Description copied from class: AbstractSubscription
      Subscribe to the given patterns
      Specified by:
      doPsubscribe in class AbstractSubscription
      Parameters:
      patterns - patterns to subscribe to
    • doPUnsubscribe

      protected void doPUnsubscribe(boolean all, byte[]... patterns)
      Description copied from class: AbstractSubscription
      Pattern unsubscribe.
      Specified by:
      doPUnsubscribe in class AbstractSubscription
      Parameters:
      all - true if all the patterns are unsubscribed (used as a hint for the underlying implementation).
      patterns - patterns to be unsubscribed
    • doSubscribe

      protected void doSubscribe(byte[]... channels)
      Description copied from class: AbstractSubscription
      Subscribe to the given channels.
      Specified by:
      doSubscribe in class AbstractSubscription
      Parameters:
      channels - channels to subscribe to
    • doUnsubscribe

      protected void doUnsubscribe(boolean all, byte[]... channels)
      Description copied from class: AbstractSubscription
      Channel unsubscribe.
      Specified by:
      doUnsubscribe in class AbstractSubscription
      Parameters:
      all - true if all the channels are unsubscribed (used as a hint for the underlying implementation).
      channels - channels to be unsubscribed