org.springframework.xd.test.fixtures

Class MqttSink

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture<MqttSink>

org.springframework.xd.test.fixtures.MqttSink

public class MqttSink
extends AbstractModuleFixture<MqttSink>

Test fixture that creates a mqtt sink.

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
protected int	port

Fields inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label

Constructor Summary

Constructors

Constructor and Description
MqttSink(java.lang.String host, int port)

Method Summary

Methods

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

Methods inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

port

protected int port

Constructor Detail

MqttSink

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

Method Detail

toDSL

protected java.lang.String toDSL()

Description copied from class: AbstractModuleFixture

Returns a representation of the module suitable for inclusion in a stream definition, e.g. file --dir=xxxx --name=yyyy

Specified by:

toDSL in class AbstractModuleFixture<MqttSink>