public class ReactorNettyTcpStompClient extends StompClientSupport
ReactorNettyTcpClient を使用する STOMP over TCP クライアント。| コンストラクターと説明 |
|---|
ReactorNettyTcpStompClient() ホスト "127.0.0.1" とポート 61613 を使用してインスタンスを作成します。 |
ReactorNettyTcpStompClient(StringSE host, int port) 指定されたホストとポートでインスタンスを作成します。 |
ReactorNettyTcpStompClient(TcpOperations<byte[]> tcpClient) 事前構成された TCP クライアントでインスタンスを作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ListenableFuture<StompSession> | connect(StompHeaders connectHeaders, StompSessionHandler handler)STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンの connect(StompSessionHandler)。 |
ListenableFuture<StompSession> | connect(StompSessionHandler handler)STOMP レベルで接続されている場合は、指定された StompSessionHandler を接続して通知します。 |
void | shutdown() クライアントをシャットダウンし、リソースを解放します。 |
StringSE | toString() |
createSession, getDefaultHeartbeat, getMessageConverter, getReceiptTimeLimit, getTaskScheduler, isDefaultHeartbeatEnabled, processConnectHeaders, setDefaultHeartbeat, setMessageConverter, setReceiptTimeLimit, setTaskSchedulercloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEpublic ReactorNettyTcpStompClient()
public ReactorNettyTcpStompClient(StringSE host, int port)
host - ザホスト port - 港 public ReactorNettyTcpStompClient(TcpOperations<byte[]> tcpClient)
tcpClient - 使用するクライアント public ListenableFuture<StompSession> connect(StompSessionHandler handler)
StompSessionHandler を接続して通知します。handler - STOMP セッションのハンドラー public ListenableFuture<StompSession> connect(@Nullable StompHeaders connectHeaders, StompSessionHandler handler)
connect(StompSessionHandler)。connectHeaders - CONNECT フレームに追加するヘッダー handler - STOMP セッションのハンドラー public void shutdown()
public StringSE toString()
ObjectSE の toStringSE