public class MqttSink extends AbstractModuleFixture<MqttSink>
| Modifier and Type | Field and Description |
|---|---|
protected int |
port |
label| Constructor and Description |
|---|
MqttSink(java.lang.String host,
int port) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.String |
toDSL()
Returns a representation of the module suitable for inclusion in a stream definition, e.g.
file --dir=xxxx --name=yyyy |
label, toStringprotected java.lang.String toDSL()
AbstractModuleFixturefile --dir=xxxx --name=yyyytoDSL in class AbstractModuleFixture<MqttSink>