public class JmsSource extends AbstractModuleFixture<JmsSource>
| 修飾子と型 | フィールドと説明 |
|---|---|
static int | DEFAULT_PORT |
protected int | port |
label| コンストラクターと説明 |
|---|
JmsSource(java.lang.String host, int port) |
| 修飾子と型 | メソッドと説明 |
|---|---|
JmsSource | ensureReady() 最大 2 秒間ポーリングして Jms ブローカーソケットが利用可能であることを確認します |
void | sendData(java.lang.String data)TCP 経由で JMS ブローカーにデータを送信します。 |
protected java.lang.String | toDSL() この フィクスチャの DSL をレンダリングします。 |
static JmsSource | withDefaultPort(java.lang.String host) デフォルトポート 61616 を使用して JmsSource インスタンスを生成します |
label, toStringpublic static final int DEFAULT_PORT
protected int port
public static JmsSource withDefaultPort(java.lang.String host)
host - JMS ブローカーが存在するホストマシン。protected java.lang.String toDSL()
AbstractModuleFixture<JmsSource> の toDSL public JmsSource ensureReady()
java.lang.IllegalStateException - 2 秒以内に接続できない場合。public void sendData(java.lang.String data)
data - JMS ブローカーに送信するデータを含む文字列。