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, toString
public 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 ブローカーに送信するデータを含む文字列。