コンストラクターの詳細

• Reactor2TcpStompClient

  public Reactor2TcpStompClient()

  ホスト "127.0.0.1" とポート 61613 を使用してインスタンスを作成します。

• Reactor2TcpStompClient

  public Reactor2TcpStompClient(StringSE host,
                                int port)

  指定されたホストとポートでインスタンスを作成し、接続します

• Reactor2TcpStompClient

  public Reactor2TcpStompClient(TcpOperations<byte[]> tcpClient)

  事前構成された TCP クライアントでインスタンスを作成します。

  パラメーター:

  tcpClient - 使用するクライアント

メソッドの詳細

• start

  public void start()

  インターフェースからコピーされた説明: Lifecycle
  このコンポーネントを起動します。

  コンポーネントがすでに実行されている場合は、例外をスローしないでください。

  コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。

  次で指定:

  インターフェース Lifecycle の start 

  関連事項:

  SmartLifecycle.isAutoStartup()

• stop

  public void stop()

  インターフェースからコピーされた説明: Lifecycle
  このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。

  この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。

  コンポーネントが実行されていない（まだ開始されていない）場合は、例外をスローしないでください。

  コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。

  次で指定:

  インターフェース Lifecycle の stop 

  関連事項:

  SmartLifecycle.stop(Runnable), DisposableBean.destroy()

• isRunning

  public boolean isRunning()

  インターフェースからコピーされた説明: Lifecycle
  このコンポーネントが現在実行されているかどうかを確認します。

  コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。

  次で指定:

  インターフェース Lifecycle の isRunning 

  戻り値:

  コンポーネントが現在実行中かどうか

• connect

  public ListenableFuture<StompSession> connect(StompSessionHandler handler)

  STOMP レベルで接続されている場合は、指定された StompSessionHandler を接続して通知します。

  パラメーター:

  handler - STOMP セッションのハンドラー

  戻り値:

  使用準備ができたときにセッションにアクセスするための ListenableFuture

• connect

  public ListenableFuture<StompSession> connect(StompHeaders connectHeaders,
                                                StompSessionHandler handler)

  STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンの connect(StompSessionHandler)。

  パラメーター:

  connectHeaders - CONNECT フレームに追加するヘッダー

  handler - STOMP セッションのハンドラー

  戻り値:

  使用準備ができたときにセッションにアクセスするための ListenableFuture

• shutdown

  public void shutdown()

  クライアントをシャットダウンし、リソースを解放します。