フィールドの詳細

• port

  protected final int port

コンストラクターの詳細

• TcpSource

  public TcpSource()

  ホストのループバックアドレスと @link AvailableSocketPorts.nextAvailablePort() によって選択されたポートを使用して新しい TcpSource を構築します

• TcpSource

  public TcpSource(java.lang.String host)

  指定されたホストと @link AvailableSocketPorts.nextAvailablePort() によって選択されたポートを使用して新しい TcpSource を構築します

  パラメーター:

  host - 接続するホスト

• TcpSource

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

  指定されたホストとポートで新しい TcpSource を構築する

  パラメーター:

  host - 接続先のホスト

  port - 接続するポート

メソッドの詳細

• withDefaults

  public static TcpSource withDefaults()

  デフォルトのホスト localhost とポート 1234 を使用して新しい TcpSource を構築します。

  戻り値:

  使用する TcpSource

• withDefaultPort

  public static TcpSource withDefaultPort(java.lang.String host)

  指定されたホストとデフォルトポート 1234 を使用して新しい TcpSource を構築します。

  パラメーター:

  host - 接続先のホスト

  戻り値:

  使用する TcpSource

• toDSL

  protected java.lang.String toDSL()

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

  次で指定:

  クラス AbstractModuleFixture<TcpSource> の toDSL 

• ensureReady

  public TcpSource ensureReady()

  TcpSource ソケットが使用可能であることを確認するために、最大 2 秒間ポーリングします。

  戻り値:

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

  例外:

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

• sendBytes

  public void sendBytes(byte[] bytes)

  指定された型を TCP ソースのホストとポートに送信します。

  パラメーター:

  bytes - 送信するデータ