public class StompBrokerRelayRegistration extends AbstractBrokerRegistration
StompBrokerRelayMessageHandler を構成するための登録クラス。| コンストラクターと説明 |
|---|
StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, java.lang.String[] destinationPrefixes) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected StompBrokerRelayMessageHandler | getMessageHandler(SubscribableChannel brokerChannel) |
protected java.lang.String | getUserDestinationBroadcast() |
protected java.lang.String | getUserRegistryBroadcast() |
StompBrokerRelayRegistration | setAutoStartup(boolean autoStartup)Spring ApplicationContext がリフレッシュされたときに StompBrokerRelayMessageHandler が自動的に起動するかどうかを構成します。 |
StompBrokerRelayRegistration | setClientLogin(java.lang.String login) 接続されたクライアントに代わって STOMP ブローカーへの接続を作成するときに使用するログインを設定します。 |
StompBrokerRelayRegistration | setClientPasscode(java.lang.String passcode) 接続されたクライアントに代わって STOMP ブローカーへの接続を作成するときに使用するパスコードを設定します。 |
StompBrokerRelayRegistration | setRelayHost(java.lang.String relayHost)STOMP メッセージブローカーホストを設定します。 |
StompBrokerRelayRegistration | setRelayPort(int relayPort)STOMP メッセージブローカーポートを設定します。 |
StompBrokerRelayRegistration | setSystemHeartbeatReceiveInterval(long heartbeatReceiveInterval) 他のデータがない場合に「システム」リレーセッションが STOMP ブローカーからハートビートを受信することを期待する最大間隔をミリ秒単位で設定します。 |
StompBrokerRelayRegistration | setSystemHeartbeatSendInterval(long systemHeartbeatSendInterval) 他のデータが送信されていない場合に「システム」リレーセッションがハートビートを STOMP ブローカーに送信する間隔をミリ秒単位で設定します。 |
StompBrokerRelayRegistration | setSystemLogin(java.lang.String login) アプリケーション内から STOMP ブローカーにメッセージを送信するために使用される共有「システム」接続のログインを設定します。 |
StompBrokerRelayRegistration | setSystemPasscode(java.lang.String passcode) アプリケーション内から STOMP ブローカーにメッセージを送信するために使用される共有「システム」接続のパスコードを設定します。 |
void | setTcpClient(TcpOperations<byte[]> tcpClient)STOMP ブローカーへの TCP 接続を管理するための TCP クライアントを構成します。 |
StompBrokerRelayRegistration | setUserDestinationBroadcast(java.lang.String destination) ユーザーが接続していないように見えるために未解決のままになっているユーザーの宛先にメッセージをブロードキャストする宛先を設定します。 |
StompBrokerRelayRegistration | setUserRegistryBroadcast(java.lang.String destination) ローカルユーザーレジストリのコンテンツをブロードキャストし、他のサーバーからのブロードキャストをリッスンする宛先を設定します。 |
StompBrokerRelayRegistration | setVirtualHost(java.lang.String virtualHost)STOMP CONNECT フレームで使用する「ホスト」ヘッダーの値を設定します。 |
getClientInboundChannel, getClientOutboundChannel, getDestinationPrefixespublic StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, java.lang.String[] destinationPrefixes)
public StompBrokerRelayRegistration setRelayHost(java.lang.String relayHost)
public StompBrokerRelayRegistration setRelayPort(int relayPort)
public StompBrokerRelayRegistration setClientLogin(java.lang.String login)
デフォルトでは「ゲスト」に設定されています。
public StompBrokerRelayRegistration setClientPasscode(java.lang.String passcode)
デフォルトでは「ゲスト」に設定されています。
public StompBrokerRelayRegistration setSystemLogin(java.lang.String login)
デフォルトでは「ゲスト」に設定されています。
public StompBrokerRelayRegistration setSystemPasscode(java.lang.String passcode)
デフォルトでは「ゲスト」に設定されています。
public StompBrokerRelayRegistration setSystemHeartbeatSendInterval(long systemHeartbeatSendInterval)
デフォルト値は 10000 です。
public StompBrokerRelayRegistration setSystemHeartbeatReceiveInterval(long heartbeatReceiveInterval)
デフォルト値は 10000 です。
public StompBrokerRelayRegistration setVirtualHost(java.lang.String virtualHost)
デフォルトでは、このプロパティは設定されていません。
public void setTcpClient(TcpOperations<byte[]> tcpClient)
デフォルトでは ReactorNettyTcpClient が使用されます。
public StompBrokerRelayRegistration setAutoStartup(boolean autoStartup)
StompBrokerRelayMessageHandler が自動的に起動するかどうかを構成します。 デフォルト設定は true です。
public StompBrokerRelayRegistration setUserDestinationBroadcast(java.lang.String destination)
デフォルトでは、これは設定されていません。
destination - 未解決のメッセージをブロードキャストする宛先。"/topic/unresolved-user-destination"@Nullable protected java.lang.String getUserDestinationBroadcast()
public StompBrokerRelayRegistration setUserRegistryBroadcast(java.lang.String destination)
デフォルトでは、これは設定されていません。
destination - ユーザーレジストリの詳細をブロードキャストする宛先。"/topic/simp-user-registry"。@Nullable protected java.lang.String getUserRegistryBroadcast()
protected StompBrokerRelayMessageHandler getMessageHandler(SubscribableChannel brokerChannel)
AbstractBrokerRegistration の getMessageHandler