org.springframework.xd.test.fixtures

Class MqttSource

java.lang.Object

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

org.springframework.xd.test.fixtures.MqttSource

public class MqttSource
extends AbstractModuleFixture<MqttSource>

A test fixture that allows testing of the mqtt source module.

Author:

Glenn Renfro

Field Summary

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

label

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
MqttSource	ensureReady() Ensure that the Mqtt broker socket is available by polling it for up to 2 seconds
void	sendData(java.lang.String data) Sends a string via Mqtt to a Rabbit Mqtt Broker.
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

Constructor Detail

MqttSource

public MqttSource(java.lang.String host)

MqttSource

public MqttSource(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<MqttSource>

ensureReady

public MqttSource ensureReady()

Ensure that the Mqtt broker socket is available by polling it for up to 2 seconds

Returns:

MqttSource to use in fluent API chaining

Throws:

java.lang.IllegalStateException - if can not connect in 2 seconds.

sendData

public void sendData(java.lang.String data)

Sends a string via Mqtt to a Rabbit Mqtt Broker.

Parameters:

data - String to be transmitted to the Mqtt Broker.