パッケージ org.springframework.messaging.simp.broker

クラス AbstractSubscriptionRegistry

java.lang.ObjectSE
org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry
実装されたすべてのインターフェース:
SubscriptionRegistry
既知の直属サブクラス
DefaultSubscriptionRegistry
public abstract class AbstractSubscriptionRegistry extends ObjectSE implements SubscriptionRegistry
SubscriptionRegistry の実装の抽象基本クラス。メッセージ内の情報を検索しますが、実際の保存と取得のために抽象メソッドに委譲します。
導入:
4.0
作成者:
Rossen Stoyanchev

  • フィールドの詳細

    • logger

      protected final Log logger

  • コンストラクターの詳細

    • AbstractSubscriptionRegistry

      public AbstractSubscriptionRegistry()

  • メソッドの詳細

    • registerSubscription

      public final void registerSubscription(Message<?> message)
      インターフェースからコピーされた説明: SubscriptionRegistry
      指定されたメッセージが表すサブスクリプションを登録します。
      次で指定:
      インターフェース SubscriptionRegistry の registerSubscription 
      パラメーター:
      message - サブスクリプションリクエスト

    • unregisterSubscription

      public final void unregisterSubscription(Message<?> message)
      インターフェースからコピーされた説明: SubscriptionRegistry
      サブスクリプションの登録を解除します。
      次で指定:
      インターフェース SubscriptionRegistry の unregisterSubscription 
      パラメーター:
      message - サブスクリプション解除のリクエスト

    • findSubscriptions

      public final MultiValueMap<StringSE,StringSE> findSubscriptions(Message<?> message)
      インターフェースからコピーされた説明: SubscriptionRegistry
      指定されたメッセージを受信するすべてのサブスクリプションを検索します。返されるマップは反復しても安全であり、変更されることはありません。
      次で指定:
      インターフェース SubscriptionRegistry の findSubscriptions 
      パラメーター:
      message - メッセージ
      戻り値:
      sessionId-subscriptionId のペアを持つ MultiValueMap (空の可能性あり)

    • addSubscriptionInternal

      protected abstract void addSubscriptionInternal(StringSE sessionId, StringSE subscriptionId, StringSE destination, Message<?> message)

    • removeSubscriptionInternal

      protected abstract void removeSubscriptionInternal(StringSE sessionId, StringSE subscriptionId, Message<?> message)

    • findSubscriptionsInternal

      protected abstract MultiValueMap<StringSE,StringSE> findSubscriptionsInternal(StringSE destination, Message<?> message)