org.springframework.xd.test.fixtures

Class RabbitSource

java.lang.Object

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

org.springframework.xd.test.fixtures.RabbitSource

public class RabbitSource
extends AbstractModuleFixture<RabbitSource>

A test fixture that allows testing of the rabbit source module.

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_EXCHANGE
static java.lang.String	DEFAULT_QUEUE

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

label

Constructor Summary

Constructors

Constructor and Description
RabbitSource(org.springframework.amqp.rabbit.connection.CachingConnectionFactory connectionFactory, java.lang.String queue) Initialize and instance of the RabbitSource

Method Summary

Methods

Modifier and Type	Method and Description
void	createQueue() Creates an instance of the queue on the rabbit broker.
void	destroyQueue() Creates an instance of the queue on the rabbit broker.
RabbitSource	ensureReady() Ensure that the Rabbit broker socket is available by polling it for up to 2 seconds
RabbitSource	queue(java.lang.String queue) Sets the queue for this fixture.
void	sendData(java.lang.String data) Sends data to the RabbitMQ Broker.
protected java.lang.String	toDSL() Renders the DSL for this fixture.
static RabbitSource	withDefaults(org.springframework.amqp.rabbit.connection.CachingConnectionFactory connectionFactory) Creates an instance of the Rabbit Source using defaults

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

DEFAULT_QUEUE

public static final java.lang.String DEFAULT_QUEUE

See Also:

Constant Field Values

DEFAULT_EXCHANGE

public static final java.lang.String DEFAULT_EXCHANGE

See Also:

Constant Field Values

Constructor Detail

RabbitSource

public RabbitSource(org.springframework.amqp.rabbit.connection.CachingConnectionFactory connectionFactory,
            java.lang.String queue)

Initialize and instance of the RabbitSource

Parameters:

connectionFactory - The MQ Connection Factory to be used by the Rabbit Source.

queue - The queue to be monitored by the source.

Method Detail

toDSL

protected java.lang.String toDSL()

Renders the DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<RabbitSource>

withDefaults

public static RabbitSource withDefaults(org.springframework.amqp.rabbit.connection.CachingConnectionFactory connectionFactory)

Creates an instance of the Rabbit Source using defaults

Parameters:

connectionFactory - the MQ Connection Factory for this source.

Returns:

A fully qualified instance of Rabbit Source

ensureReady

public RabbitSource ensureReady()

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

Returns:

RabbitSource to use in fluent API chaining

Throws:

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

createQueue

public void createQueue()

Creates an instance of the queue on the rabbit broker. If already present then no action is taken.

destroyQueue

public void destroyQueue()

Creates an instance of the queue on the rabbit broker. If already present then no action is taken.

sendData

public void sendData(java.lang.String data)

Sends data to the RabbitMQ Broker.

Parameters:

data - String to be transmitted to the Broker.

queue

public RabbitSource queue(java.lang.String queue)

Sets the queue for this fixture.

Parameters:

queue - the name of the queue to be associated with this source.

Returns:

The current instance of RabbitSource