org.springframework.data.redis.connection.lettuce

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	LettuceSubscription(MessageListener listener, io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> pubsubConnection, LettuceConnectionProvider connectionProvider) Creates a new LettuceSubscription given MessageListener, StatefulRedisPubSubConnection, and LettuceConnectionProvider.

Method Summary

Modifier and Type	Method and Description
protected void	doClose() Shutdown the subscription and free any resources held.
protected void	doPsubscribe(byte[]... patterns) Subscribe to the given patterns
protected void	doPUnsubscribe(boolean all, byte[]... patterns) Pattern unsubscribe.
protected void	doSubscribe(byte[]... channels) Subscribe to the given channels.
protected void	doUnsubscribe(boolean all, byte[]... channels) Channel unsubscribe.
protected io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]>	getNativeConnection()

Methods inherited from class org.springframework.data.redis.connection.util.AbstractSubscription

close, getChannels, getListener, getPatterns, isAlive, pSubscribe, pUnsubscribe, pUnsubscribe, subscribe, unsubscribe, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LettuceSubscription

protected LettuceSubscription(MessageListener listener,
                              io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> pubsubConnection,
                              LettuceConnectionProvider connectionProvider)

Creates a new LettuceSubscription given MessageListener, StatefulRedisPubSubConnection, and LettuceConnectionProvider.

Parameters:

listener - the listener to notify, must not be null.

pubsubConnection - must not be null.

connectionProvider - must not be null.

Method Detail

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