public class LettuceSubscription extends AbstractSubscription
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 . |
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() |
close, getChannels, getListener, getPatterns, isAlive, pSubscribe, pUnsubscribe, pUnsubscribe, subscribe, unsubscribe, unsubscribe
protected LettuceSubscription(MessageListener listener, io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> pubsubConnection, LettuceConnectionProvider connectionProvider)
LettuceSubscription
given MessageListener
, StatefulRedisPubSubConnection
, and
LettuceConnectionProvider
.listener
- the listener to notify, must not be null.pubsubConnection
- must not be null.connectionProvider
- must not be null.protected io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> getNativeConnection()
protected void doClose()
AbstractSubscription
doClose
in class AbstractSubscription
protected void doPsubscribe(byte[]... patterns)
AbstractSubscription
doPsubscribe
in class AbstractSubscription
patterns
- patterns to subscribe toprotected void doPUnsubscribe(boolean all, byte[]... patterns)
AbstractSubscription
doPUnsubscribe
in class AbstractSubscription
all
- true if all the patterns are unsubscribed (used as a hint for the underlying implementation).patterns
- patterns to be unsubscribedprotected void doSubscribe(byte[]... channels)
AbstractSubscription
doSubscribe
in class AbstractSubscription
channels
- channels to subscribe toprotected void doUnsubscribe(boolean all, byte[]... channels)
AbstractSubscription
doUnsubscribe
in class AbstractSubscription
all
- true if all the channels are unsubscribed (used as a hint for the underlying implementation).channels
- channels to be unsubscribedCopyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.