org.springframework.xd.test.fixtures

Class TcpSource

java.lang.Object

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

org.springframework.xd.test.fixtures.TcpSource

public class TcpSource
extends AbstractModuleFixture<TcpSource>

A test fixture that allows testing of the 'tcp' source module.

Author:

Eric Bottard, 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
TcpSource() Construct a new TcpSource with the loopback address for host and using a port selected by @link AvailableSocketPorts.nextAvailablePort()
TcpSource(java.lang.String host) Construct a new TcpSource with the provided host and using a port selected by @link AvailableSocketPorts.nextAvailablePort()
TcpSource(java.lang.String host, int port) Construct a new TcpSource with the provided host and port

Method Summary

Methods

Modifier and Type	Method and Description
TcpSource	ensureReady() Ensure that the TcpSource socket is available by polling it for up to 2 seconds
void	sendBytes(byte[] bytes) Send the specified types to the host and and port of the TCP source.
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
static TcpSource	withDefaultPort(java.lang.String host) Construct a new TcpSource using the provided host and the default port of 1234
static TcpSource	withDefaults() Construct a new TcpSource using the default host of localhost and port of 1234

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 final int port

Constructor Detail

TcpSource

public TcpSource()

Construct a new TcpSource with the loopback address for host and using a port selected by @link AvailableSocketPorts.nextAvailablePort()

TcpSource

public TcpSource(java.lang.String host)

Construct a new TcpSource with the provided host and using a port selected by @link AvailableSocketPorts.nextAvailablePort()

Parameters:

host - the host to connect to

TcpSource

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

Construct a new TcpSource with the provided host and port

Parameters:

host - host to connect to

port - port to connect to

Method Detail

withDefaults

public static TcpSource withDefaults()

Construct a new TcpSource using the default host of localhost and port of 1234

Returns:

TcpSource to use

withDefaultPort

public static TcpSource withDefaultPort(java.lang.String host)

Construct a new TcpSource using the provided host and the default port of 1234

Parameters:

host - host to connect to

Returns:

TcpSource to use

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<TcpSource>

ensureReady

public TcpSource ensureReady()

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

Returns:

TcpSource to use in fluent API chaining

Throws:

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

sendBytes

public void sendBytes(byte[] bytes)

Send the specified types to the host and and port of the TCP source.

Parameters:

bytes - data to send