org.springframework.xd.integration.fixtures

Class Sinks

java.lang.Object

org.springframework.xd.integration.fixtures.Sinks

public class Sinks
extends java.lang.Object

A factory that provides fully instantiated sink fixtures based on the environment selected at test startup.

Author:

Glenn Renfro

Constructor Summary

Constructors

Constructor and Description
Sinks(XdEnvironment environment) Initializes the instance with xdEnvironment

Method Summary

Methods

Modifier and Type	Method and Description
SimpleFileSink	file() Construct a new fileSink that will write the result to the xd output directory using the stream name as the filename.
SimpleFileSink	file(java.lang.String dir, java.lang.String fileName) Construct a new fileSink that will write the result to the dir and filename specified.
HdfsSink	hdfs() Constructs a hdfs sink with a directory of /xd/acceptancetest & a file name of ACCTEST
JdbcSink	jdbc() Construct a new jdbcSink that will write the output to a table .
LogSink	log() Construct a new logSink that will write output to the XD log.
MqttSink	mqtt() Construct a new Mqttsink using the default RabbitMQ (MQTT-enbaled) broker host as specified in the environment.
RabbitSink	rabbit(java.lang.String routingKey) Construct a new rabbitSink that will push messages to rabbit broker.
TcpSink	tcp() Construct a new TcpSink with the default target host taken from the environment and default port (1234)
TcpSink	tcp(int port) Construct a new TcpSink with the default target host taken from the environment and the provided port.
TcpSink	tcp(java.lang.String host) Construct a new TcpSink with the target host and the default port.

Methods inherited from class java.lang.Object

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

Constructor Detail

Sinks

public Sinks(XdEnvironment environment)

Initializes the instance with xdEnvironment

Parameters:

environment -

Method Detail

tcp

public TcpSink tcp()

Construct a new TcpSink with the default target host taken from the environment and default port (1234)

Returns:

an instance of TcpSink

tcp

public TcpSink tcp(java.lang.String host)

Construct a new TcpSink with the target host and the default port.

Parameters:

host - the host the where the tcp sink will connect to

Returns:

an instance of TcpSink

tcp

public TcpSink tcp(int port)

Construct a new TcpSink with the default target host taken from the environment and the provided port.

Parameters:

port - the port to connect to

Returns:

an instance of TcpSink

mqtt

public MqttSink mqtt()

Construct a new Mqttsink using the default RabbitMQ (MQTT-enbaled) broker host as specified in the environment.

Returns:

a mqtt sink

file

public SimpleFileSink file(java.lang.String dir,
                  java.lang.String fileName)

Construct a new fileSink that will write the result to the dir and filename specified.

Parameters:

dir - the directory the file will be written.

fileName - the name of file to be written.

Returns:

an instantiated file sink

file

public SimpleFileSink file()

Construct a new fileSink that will write the result to the xd output directory using the stream name as the filename.

Returns:

an instantiated file sink

log

public LogSink log()

Construct a new logSink that will write output to the XD log.

Returns:

a LogSink instance.

jdbc

public JdbcSink jdbc()

Construct a new jdbcSink that will write the output to a table .

Returns:

a JdbcSink instance.

hdfs

public HdfsSink hdfs()

Constructs a hdfs sink with a directory of /xd/acceptancetest & a file name of ACCTEST

Returns:

An instantiated instance of hdfs sink fixture.

rabbit

public RabbitSink rabbit(java.lang.String routingKey)

Construct a new rabbitSink that will push messages to rabbit broker.

Returns:

an instantiated rabbit sink