クラス ReactorNettyTcpStompClient
java.lang.ObjectSE
org.springframework.messaging.simp.stomp.StompClientSupport
org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient
ReactorNettyTcpClient または ReactorNetty2TcpClient で構成可能な STOMP over TCP クライアント。- 導入:
- 5.0
- 作成者:
- Rossen Stoyanchev
コンストラクターのサマリー
コンストラクターコンストラクター説明ホスト "127.0.0.1" とポート 61613 を使用してインスタンスを作成します。ReactorNettyTcpStompClient(StringSE host, int port) 指定されたホストとポートでインスタンスを作成します。ReactorNettyTcpStompClient(TcpOperations<byte[]> tcpClient) 事前構成された TCP クライアントでインスタンスを作成します。メソッドのサマリー
修飾子と型メソッド説明connect(StompHeaders connectHeaders, StompSessionHandler handler) 使用すべきではありません。connect(StompSessionHandler handler) 使用すべきではありません。6.0 現在、connectAsync(StompSessionHandler)を推奨connectAsync(StompHeaders connectHeaders, StompSessionHandler handler) STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンのconnectAsync(StompSessionHandler)。connectAsync(StompSessionHandler handler) STOMP レベルで接続されている場合は、指定されたStompSessionHandlerを接続して通知します。voidshutdown()クライアントをシャットダウンし、リソースを解放します。toString()クラス org.springframework.messaging.simp.stomp.StompClientSupport から継承されたメソッド
createSession, getDefaultHeartbeat, getMessageConverter, getReceiptTimeLimit, getTaskScheduler, isDefaultHeartbeatEnabled, processConnectHeaders, setDefaultHeartbeat, setMessageConverter, setReceiptTimeLimit, setTaskScheduler
コンストラクターの詳細
ReactorNettyTcpStompClient
public ReactorNettyTcpStompClient()ホスト "127.0.0.1" とポート 61613 を使用してインスタンスを作成します。ReactorNettyTcpStompClient
指定されたホストとポートでインスタンスを作成します。- パラメーター:
host- ザホストport- 港
ReactorNettyTcpStompClient
事前構成された TCP クライアントでインスタンスを作成します。- パラメーター:
tcpClient- 使用するクライアント
メソッドの詳細
connect
@DeprecatedSE(since="6.0") public ListenableFuture<StompSession> connect(StompSessionHandler handler) 使用すべきではありません。6.0 現在、connectAsync(StompSessionHandler)を推奨STOMP レベルで接続されている場合は、指定されたStompSessionHandlerを接続して通知します。- パラメーター:
handler- STOMP セッションのハンドラー- 戻り値:
- 使用の準備ができたときにセッションにアクセスするための ListenableFuture
connectAsync
STOMP レベルで接続されている場合は、指定されたStompSessionHandlerを接続して通知します。- パラメーター:
handler- STOMP セッションのハンドラー- 戻り値:
- 使用の準備ができたときにセッションにアクセスするための CompletableFuture
- 導入:
- 6.0
connect
@DeprecatedSE(since="6.0") public ListenableFuture<StompSession> connect(@Nullable StompHeaders connectHeaders, StompSessionHandler handler) 使用すべきではありません。STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンのconnect(StompSessionHandler)。- パラメーター:
connectHeaders- CONNECT フレームに追加するヘッダーhandler- STOMP セッションのハンドラー- 戻り値:
- 使用の準備ができたときにセッションにアクセスするための ListenableFuture
connectAsync
public CompletableFutureSE<StompSession> connectAsync(@Nullable StompHeaders connectHeaders, StompSessionHandler handler) STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンのconnectAsync(StompSessionHandler)。- パラメーター:
connectHeaders- CONNECT フレームに追加するヘッダーhandler- STOMP セッションのハンドラー- 戻り値:
- 使用の準備ができたときにセッションにアクセスするための CompletableFuture
shutdown
public void shutdown()クライアントをシャットダウンし、リソースを解放します。toString
connectAsync(StompHeaders, StompSessionHandler)を推奨