クラス StompBrokerRelayRegistration

java.lang.ObjectSE
org.springframework.messaging.simp.config.AbstractBrokerRegistration
org.springframework.messaging.simp.config.StompBrokerRelayRegistration

public class StompBrokerRelayRegistration extends AbstractBrokerRegistration
StompBrokerRelayMessageHandler を構成するための登録クラス。
導入:
4.0
作成者:
Rossen Stoyanchev
  • コンストラクターの詳細

    • StompBrokerRelayRegistration

      public StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, StringSE[] destinationPrefixes)
      新しい StompBrokerRelayRegistration を作成します。
      パラメーター:
      clientInboundChannel - 受信チャネル
      clientOutboundChannel - 送信チャネル
      destinationPrefixes - 宛先プレフィックス
  • メソッドの詳細

    • setRelayHost

      public StompBrokerRelayRegistration setRelayHost(StringSE relayHost)
      STOMP メッセージブローカーホストを設定します。
    • setRelayPort

      public StompBrokerRelayRegistration setRelayPort(int relayPort)
      STOMP メッセージブローカーポートを設定します。
    • setClientLogin

      public StompBrokerRelayRegistration setClientLogin(StringSE login)
      接続されたクライアントに代わって STOMP ブローカーへの接続を作成するときに使用するログインを設定します。

      デフォルトでは「ゲスト」に設定されています。

    • setClientPasscode

      public StompBrokerRelayRegistration setClientPasscode(StringSE passcode)
      接続されたクライアントに代わって STOMP ブローカーへの接続を作成するときに使用するパスコードを設定します。

      デフォルトでは「ゲスト」に設定されています。

    • setSystemLogin

      public StompBrokerRelayRegistration setSystemLogin(StringSE login)
      アプリケーション内から STOMP ブローカーにメッセージ (つまり、特定のクライアントセッションに関連付けられていないメッセージ (たとえば、REST/HTTP リクエスト処理メソッド)) を送信するために使用される共有「システム」接続のログインを設定します。

      デフォルトでは「ゲスト」に設定されています。

    • setSystemPasscode

      public StompBrokerRelayRegistration setSystemPasscode(StringSE passcode)
      アプリケーション内から STOMP ブローカーにメッセージ (つまり、特定のクライアントセッションに関連付けられていないメッセージ (たとえば、REST/HTTP リクエスト処理メソッド)) を送信するために使用される共有「システム」接続のパスコードを設定します。

      デフォルトでは「ゲスト」に設定されています。

    • setSystemHeartbeatSendInterval

      public StompBrokerRelayRegistration setSystemHeartbeatSendInterval(long systemHeartbeatSendInterval)
      他のデータが送信されていない場合に「システム」リレーセッションがハートビートを STOMP ブローカーに送信する間隔をミリ秒単位で設定します。値をゼロにすると、ハートビートがブローカーに送信されなくなります。

      デフォルト値は 10000 です。

    • setSystemHeartbeatReceiveInterval

      public StompBrokerRelayRegistration setSystemHeartbeatReceiveInterval(long heartbeatReceiveInterval)
      他のデータがない場合に「システム」リレーセッションが STOMP ブローカーからハートビートを受信することを期待する最大間隔をミリ秒単位で設定します。ゼロの値は、ブローカーからハートビートを受信しないことを期待するようにリレーセッションを構成します。

      デフォルト値は 10000 です。

    • setVirtualHost

      public StompBrokerRelayRegistration setVirtualHost(StringSE virtualHost)
      STOMP CONNECT フレームで使用する「ホスト」ヘッダーの値を設定します。このプロパティを設定すると、STOMP ブローカーに送信されるすべての STOMP フレームに「ホスト」ヘッダーが追加されます。これは、たとえば、TCP 接続が確立される実際のホストがクラウドベースの STOMP サービスを提供するホストと異なるクラウド環境で役立つ場合があります。

      デフォルトでは、このプロパティは設定されていません。

    • setTcpClient

      public StompBrokerRelayRegistration setTcpClient(TcpOperations<byte[]> tcpClient)
      STOMP ブローカーへの TCP 接続を管理するための TCP クライアントを構成します。

      デフォルトでは ReactorNettyTcpClient が使用されます。

      注意 : このプロパティを使用すると、指定された host または port は事実上無視されます。

      導入:
      4.3.15
    • setTaskScheduler

      public StompBrokerRelayRegistration setTaskScheduler(@Nullable TaskScheduler taskScheduler)
      一部の STOMP クライアント (たとえば、stomp-js) は常に固定レートでハートビートを送信しますが、他のクライアント (Spring STOMP クライアント) は他のメッセージが送信されていない場合にのみハートビートを送信します。ただし、非ブローカー destination prefix のメッセージは転送されないため、ブローカーは接続を非アクティブと見なす場合があります。

      この TaskScheduler が設定されている場合、現在のハートビート期間の開始以降にクライアントからブローカーに送信されたメッセージの数のカウントをリセットするために使用されます。次に、これを使用して、ブローカー以外の宛先プレフィックスを持つメッセージを無視するときに、ブローカーにハートビートを送信するかどうかを決定します。

      導入:
      5.3
    • setAutoStartup

      public StompBrokerRelayRegistration setAutoStartup(boolean autoStartup)
      Spring ApplicationContext がリフレッシュされたときに StompBrokerRelayMessageHandler が自動的に起動するかどうかを構成します。

      デフォルト設定は true です。

    • setUserDestinationBroadcast

      public StompBrokerRelayRegistration setUserDestinationBroadcast(StringSE destination)
      ユーザーが接続していないように見えるために未解決のままになっているユーザーの宛先にメッセージをブロードキャストする宛先を設定します。マルチアプリケーションサーバーのシナリオでは、これにより他のアプリケーションサーバーが試す機会が与えられます。

      デフォルトでは、これは設定されていません。

      パラメーター:
      destination - 未解決メッセージをブロードキャストする宛先(例: "/topic/unresolved-user-destination")
    • getUserDestinationBroadcast

      @Nullable protected StringSE getUserDestinationBroadcast()
    • setUserRegistryBroadcast

      public StompBrokerRelayRegistration setUserRegistryBroadcast(StringSE destination)
      ローカルユーザーレジストリのコンテンツをブロードキャストし、他のサーバーからのブロードキャストをリッスンする宛先を設定します。マルチアプリケーションサーバーのシナリオでは、これにより、各サーバーのユーザーレジストリが他のサーバーに接続しているユーザーを認識することができます。

      デフォルトでは、これは設定されていません。

      パラメーター:
      destination - ユーザーレジストリの詳細をブロードキャストする宛先 (例: "/topic/simp-user-registry")。
    • getUserRegistryBroadcast

      @Nullable protected StringSE getUserRegistryBroadcast()
    • getMessageHandler

      protected StompBrokerRelayMessageHandler getMessageHandler(SubscribableChannel brokerChannel)
      次で指定:
      クラス AbstractBrokerRegistrationgetMessageHandler