org.springframework.xd.test.fixtures

Class SimpleHttpSource

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture

org.springframework.xd.test.fixtures.SimpleHttpSource

public class SimpleHttpSource
extends AbstractModuleFixture

Author:

Glenn Renfro

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
SimpleHttpSource	ensureReady() Attempts connections to the source until it is ready to accept data.
SimpleHttpSource	ensureReady(int timeout)
void	postData(java.lang.String payload)
void	postFromFile(java.io.File 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

toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleHttpSource

public SimpleHttpSource(int port)
                 throws java.lang.Exception

Throws:

java.lang.Exception

SimpleHttpSource

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

Throws:

java.lang.Exception

Method Detail

ensureReady

public SimpleHttpSource ensureReady()

Attempts connections to the source until it is ready to accept data.

ensureReady

public SimpleHttpSource ensureReady(int 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

postData

public void postData(java.lang.String payload)
              throws java.lang.Exception

Throws:

java.lang.Exception

postFromFile

public void postFromFile(java.io.File file)
                  throws java.lang.Exception

Throws:

java.lang.Exception