org.springframework.xd.test.fixtures

Class SimpleHttpSource

java.lang.Object

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

org.springframework.xd.test.fixtures.SimpleHttpSource

public class SimpleHttpSource
extends AbstractModuleFixture<SimpleHttpSource>

An HTTP source that default to using localhost:9000

Author:

Glenn Renfro, Mark Pollack

Field Summary

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

label

Constructor Summary

Constructors

Constructor and Description
SimpleHttpSource() Construct a new SimpleHttpSource, given a host.
SimpleHttpSource(java.lang.String host) Construct a new SimpleHttpSource, given a host.
SimpleHttpSource(java.lang.String host, int port) Construct a new SimpleHttpSource, given a host and a port connect to.

Method Summary

Methods

Modifier and Type	Method and Description
SimpleHttpSource	ensureReady() Ensure that the source is ready to take requests by sending http header requests to the source for up to 2 seconds.
SimpleHttpSource	ensureReady(int timeoutInMillis) Ensure that the source is ready to take requests by sending http header requests for up to the timeout specified in millisecionds, sleeping 100 ms between attempts.
void	postData(java.lang.String payload) Make a HTTP POST request using the provided string in the http body.
void	postFromFile(java.io.File file) Generate a http request from the contents of a file
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

SimpleHttpSource

public SimpleHttpSource()

Construct a new SimpleHttpSource, given a host. The port will default to 9000.

SimpleHttpSource

public SimpleHttpSource(java.lang.String host)

Construct a new SimpleHttpSource, given a host. The port will default to 9000.

Parameters:

host - the host to connect to

SimpleHttpSource

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

Construct a new SimpleHttpSource, given a host and a port connect to.

Parameters:

host - The host to connect to

port - The port to connect to

Method Detail

ensureReady

public SimpleHttpSource ensureReady()

Ensure that the source is ready to take requests by sending http header requests to the source for up to 2 seconds.

Throws:

java.lang.IllegalStateException - if can't connect to the source within the given timeout.

ensureReady

public SimpleHttpSource ensureReady(int timeoutInMillis)

Ensure that the source is ready to take requests by sending http header requests for up to the timeout specified in millisecionds, sleeping 100 ms between attempts.

Parameters:

timeoutInMillis -

Returns:

a new SimpleHttpSource

Throws:

java.lang.IllegalStateException - if can't connect to the source within the given timeout.

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

postData

public void postData(java.lang.String payload)

Make a HTTP POST request using the provided string in the http body.

Parameters:

payload - String to send in the http body.

postFromFile

public void postFromFile(java.io.File file)

Generate a http request from the contents of a file

Parameters:

file - the File that contains the data to post

Throws:

GeneratorException - If there was an error related to file handling.