コンストラクターの詳細

• MqttSource

  public MqttSource(java.lang.String host)

• MqttSource

  public MqttSource(java.lang.String host,
            int port)

メソッドの詳細

• toDSL

  protected java.lang.String toDSL()

  クラスからコピーされた説明: AbstractModuleFixture
  ストリーム定義に含めるのに適したモジュールの表現を返します。 例:  file --dir=xxxx --name=yyyy

  次で指定:

  クラス AbstractModuleFixture<MqttSource> の toDSL 

• ensureReady

  public MqttSource ensureReady()

  最大 2 秒間ポーリングして、Mqtt ブローカーソケットが利用可能であることを確認します。

  戻り値:

  流れるような API チェーンで使用する MqttSource

  例外:

  java.lang.IllegalStateException - 2 秒以内に接続できない場合。

• sendData

  public void sendData(java.lang.String data)

  Mqtt 経由で文字列を Rabbit Mqtt ブローカーに送信します。

  パラメーター:

  data - Mqtt ブローカーに送信される文字列。