org.springframework.xd.integration.fixtures

Class Sinks

java.lang.Object

org.springframework.xd.integration.fixtures.ModuleFixture

org.springframework.xd.integration.fixtures.Sinks

public class Sinks
extends ModuleFixture

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
SimpleCounterSink	counterSink(java.lang.String name) Constructs a Counter Sink for capturing count metrics.
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.
GemFireServerSink	gemfireServer(java.lang.String region) Construct a new GemfireServer sink.
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 .
KafkaSink	kafkaSink() Constructs a new KafkaSink
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.
TcpSink	tcpSink() Construct a new TcpSink with the target host resolved at runtime from the default stream name.

Methods inherited from class org.springframework.xd.integration.fixtures.ModuleFixture

getContainerResolver, setContainerResolver

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

tcpSink

public TcpSink tcpSink()

Construct a new TcpSink with the target host resolved at runtime from the default stream name.

Returns:

an instance of TcpSource configured with host and port of http module deployed at runtime.

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

gemfireServer

public GemFireServerSink gemfireServer(java.lang.String region)

Construct a new GemfireServer sink.

Parameters:

region - the name of the region bound to this sink

Returns:

an instance of GemFireServerSink

counterSink

public SimpleCounterSink counterSink(java.lang.String name)

Constructs a Counter Sink for capturing count metrics.

Parameters:

name - The identifier for the results in the metrics store

Returns:

an instance of SimpleCounterSink

kafkaSink

public KafkaSink kafkaSink()

Constructs a new KafkaSink

Returns:

a new instance of KafkaSink