クラス LettuceSubscription
java.lang.ObjectSE
org.springframework.data.redis.connection.util.AbstractSubscription
org.springframework.data.redis.connection.lettuce.LettuceSubscription
- 実装されたすべてのインターフェース:
Subscription
Lettuce に加えてメッセージサブスクリプション。
- 作成者:
- Costin Leau, Mark Paluch, Christoph Strobl, Sarah Abbey, Murtuza Boxwala, Jens Deppe
コンストラクターの概要
コンストラクター修飾子コンストラクター説明protected
LettuceSubscription
(MessageListener listener, io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[], byte[]> pubsubConnection, LettuceConnectionProvider connectionProvider) MessageListener
、StatefulRedisPubSubConnection
、LettuceConnectionProvider
を指定して新しいLettuceSubscription
を作成します。メソッドのサマリー
修飾子と型メソッド説明protected void
doClose()
サブスクリプションをシャットダウンし、保持されているリソースをすべて解放します。protected void
doPsubscribe
(byte[]... patterns) 与えられたパターンを購読するprotected void
doPUnsubscribe
(boolean all, byte[]... patterns) パターンの購読解除。protected void
doSubscribe
(byte[]... channels) 指定されたチャネルにサブスクライブします。protected void
doUnsubscribe
(boolean all, byte[]... channels) チャンネル登録解除。protected io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],
byte[]> クラス org.springframework.data.redis.connection.util.AbstractSubscription から継承されたメソッド
close, getChannels, getListener, getPatterns, isAlive, pSubscribe, pUnsubscribe, pUnsubscribe, subscribe, unsubscribe, unsubscribe
コンストラクターの詳細
LettuceSubscription
protected LettuceSubscription(MessageListener listener, io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[], byte[]> pubsubConnection, LettuceConnectionProvider connectionProvider) MessageListener
、StatefulRedisPubSubConnection
、LettuceConnectionProvider
を指定して新しいLettuceSubscription
を作成します。- パラメーター:
listener
- 通知するリスナーは null であってはなりません。pubsubConnection
- null であってはなりません。connectionProvider
- null であってはなりません。
メソッドの詳細
getNativeConnection
protected io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> getNativeConnection()doClose
protected void doClose()クラスからコピーされた説明:AbstractSubscription
サブスクリプションをシャットダウンし、保持されているリソースをすべて解放します。- 次で指定:
- クラス
AbstractSubscription
のdoClose
doPsubscribe
protected void doPsubscribe(byte[]... patterns) クラスからコピーされた説明:AbstractSubscription
与えられたパターンを購読する- 次で指定:
- クラス
AbstractSubscription
のdoPsubscribe
- パラメーター:
patterns
- サブスクライブするパターン
doPUnsubscribe
protected void doPUnsubscribe(boolean all, byte[]... patterns) クラスからコピーされた説明:AbstractSubscription
パターンの購読解除。- 次で指定:
- クラス
AbstractSubscription
のdoPUnsubscribe
- パラメーター:
all
- すべてのパターンがサブスクライブされていない場合は true(基礎となる実装のヒントとして使用)。patterns
- 退会するパターン
doSubscribe
protected void doSubscribe(byte[]... channels) クラスからコピーされた説明:AbstractSubscription
指定されたチャネルにサブスクライブします。- 次で指定:
- クラス
AbstractSubscription
のdoSubscribe
- パラメーター:
channels
- サブスクライブするチャネル
doUnsubscribe
protected void doUnsubscribe(boolean all, byte[]... channels) クラスからコピーされた説明:AbstractSubscription
チャンネル登録解除。- 次で指定:
- クラス
AbstractSubscription
のdoUnsubscribe
- パラメーター:
all
- すべてのチャネルがサブスクライブされていない場合は true(基礎となる実装のヒントとして使用)。channels
- 退会するチャンネル