public class Reactor2TcpStompClient extends StompClientSupport implements Lifecycle
Reactor2TcpClient を使用する STOMP over TCP クライアント。logger| コンストラクターと説明 |
|---|
Reactor2TcpStompClient() ホスト "127.0.0.1" とポート 61613 を使用してインスタンスを作成します。 |
Reactor2TcpStompClient(StringSE host, int port) 指定されたホストとポートでインスタンスを作成し、接続します |
Reactor2TcpStompClient(TcpOperations<byte[]> tcpClient) 事前構成された TCP クライアントでインスタンスを作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ListenableFuture<StompSession> | connect(StompHeaders connectHeaders, StompSessionHandler handler)STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンの connect(StompSessionHandler)。 |
ListenableFuture<StompSession> | connect(StompSessionHandler handler)STOMP レベルで接続されている場合は、指定された StompSessionHandler を接続して通知します。 |
boolean | isRunning() このコンポーネントが現在実行されているかどうかを確認します。 |
void | shutdown() クライアントをシャットダウンし、リソースを解放します。 |
void | start() このコンポーネントを起動します。 |
void | stop() このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。 |
createSession, getDefaultHeartbeat, getMessageConverter, getReceiptTimeLimit, getTaskScheduler, isDefaultHeartbeatEnabled, processConnectHeaders, setDefaultHeartbeat, setMessageConverter, setReceiptTimeLimit, setTaskSchedulercloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic Reactor2TcpStompClient()
public Reactor2TcpStompClient(StringSE host, int port)
public Reactor2TcpStompClient(TcpOperations<byte[]> tcpClient)
tcpClient - 使用するクライアント public void start()
Lifecycleコンポーネントがすでに実行されている場合は、例外をスローしないでください。
コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。
Lifecycle の start SmartLifecycle.isAutoStartup()public void stop()
LifecycleSmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。 この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。
コンポーネントが実行されていない(まだ開始されていない)場合は、例外をスローしないでください。
コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。
Lifecycle の stop SmartLifecycle.stop(Runnable), DisposableBean.destroy()public boolean isRunning()
Lifecycle コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。
public ListenableFuture<StompSession> connect(StompSessionHandler handler)
StompSessionHandler を接続して通知します。handler - STOMP セッションのハンドラー public ListenableFuture<StompSession> connect(StompHeaders connectHeaders, StompSessionHandler handler)
connect(StompSessionHandler)。connectHeaders - CONNECT フレームに追加するヘッダー handler - STOMP セッションのハンドラー public void shutdown()