public class JmsSource extends AbstractModuleFixture<JmsSource>
| Modifier and Type | Field and Description |
|---|---|
static int |
DEFAULT_PORT |
protected int |
port |
label| Constructor and Description |
|---|
JmsSource(java.lang.String host,
int port) |
| Modifier and Type | Method and Description |
|---|---|
JmsSource |
ensureReady()
Ensure that the Jms broker socket is available by polling it for up to 2 seconds
|
void |
sendData(java.lang.String data)
Sends data to the JMS broker via TCP.
|
protected java.lang.String |
toDSL()
Renders the DSL for this fixture.
|
static JmsSource |
withDefaultPort(java.lang.String host)
Generates a JmsSource instance using the default port 61616
|
label, toStringpublic static final int DEFAULT_PORT
protected int port
public static JmsSource withDefaultPort(java.lang.String host)
host - The host machine where the JMS broker exists.protected java.lang.String toDSL()
toDSL in class AbstractModuleFixture<JmsSource>public JmsSource ensureReady()
java.lang.IllegalStateException - if can not connect in 2 seconds.public void sendData(java.lang.String data)
data - A string containing the data to send to the JMS broker.