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

クラス UserRegistryMessageHandler

java.lang.ObjectSE
org.springframework.messaging.simp.user.UserRegistryMessageHandler
実装されたすべてのインターフェース:
EventListenerSE、ApplicationListener<BrokerAvailabilityEvent>、MessageHandler
public class UserRegistryMessageHandler extends ObjectSE implements MessageHandler, ApplicationListener<BrokerAvailabilityEvent>
他のアプリケーションサーバーからのユーザーレジストリブロードキャストを処理し、ローカルユーザーレジストリのコンテンツを定期的にブロードキャストする MessageHandler。

集約された情報は MultiServerUserRegistry に保持されます。

導入:
4.2
作成者:
Rossen Stoyanchev

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

    • UserRegistryMessageHandler

      public UserRegistryMessageHandler(MultiServerUserRegistry userRegistry, SimpMessagingTemplate brokerTemplate, StringSE broadcastDestination, TaskScheduler scheduler)
      コンストラクター。
      パラメーター:
      userRegistry - ローカルおよびリモートユーザーレジストリ情報を含むレジストリ
      brokerTemplate - ローカルレジストリ情報をブロードキャストするためのテンプレート
      broadcastDestination - ブロードキャスト先
      scheduler - 使用するタスクスケジューラ

  • メソッドの詳細

    • getBroadcastDestination

      public StringSE getBroadcastDestination()
      UserRegistry 情報をブロードキャストするために構成された宛先を返します。

    • setRegistryExpirationPeriod

      public void setRegistryExpirationPeriod(long milliseconds)
      リモートユーザーレジストリスナップショットが期限切れと見なされるまでの時間（ミリ秒単位）を構成します。

      デフォルトでは 20 秒に設定されています（20000 の値）。

      パラメーター:
      milliseconds - ミリ秒単位の有効期限

    • getRegistryExpirationPeriod

      public long getRegistryExpirationPeriod()
      構成されたレジストリの有効期限を返します。

    • onApplicationEvent

      public void onApplicationEvent(BrokerAvailabilityEvent event)
      インターフェースからコピーされた説明: ApplicationListener
      アプリケーションイベントを処理します。
      次で指定:
      インターフェース ApplicationListener<BrokerAvailabilityEvent> の onApplicationEvent 
      パラメーター:
      event - 応答するイベント

    • handleMessage

      public void handleMessage(Message<?> message) throws MessagingException
      インターフェースからコピーされた説明: MessageHandler
      指定されたメッセージを処理します。
      次で指定:
      インターフェース MessageHandler の handleMessage 
      パラメーター:
      message - 処理するメッセージ
      例外:
      MessagingException - ハンドラーがメッセージの処理に失敗した場合