com.consol.citrus.channel

Class ChannelSyncProducer

java.lang.Object

com.consol.citrus.channel.ChannelProducer

com.consol.citrus.channel.ChannelSyncProducer

All Implemented Interfaces:

Consumer, Producer, ReplyConsumer, SelectiveConsumer

public class ChannelSyncProducer
extends ChannelProducer
implements ReplyConsumer

Synchronous producer sends message to in memory message channel and receives synchronous reply. Reply message is correlated and stored in correlation manager. This way test cases are able to receive synchronous message asynchronously at later time.

Since:

1.4

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
ChannelSyncProducer(String name, ChannelSyncEndpointConfiguration endpointConfiguration) Default constructor using endpoint configuration.

Method Summary

Modifier and Type	Method and Description
CorrelationManager<Message>	getCorrelationManager() Gets the correlation manager.
Message	receive(String selector, TestContext context) Receive message with a message selector and default timeout.
Message	receive(String selector, TestContext context, long timeout) Receive message with a message selector and a receive timeout.
Message	receive(TestContext context) Receive message with default timeout.
Message	receive(TestContext context, long timeout) Receive message with a given timeout.
void	send(Message message, TestContext context) Sends the message.
void	setCorrelationManager(CorrelationManager<Message> correlationManager) Sets the correlation manager.

Methods inherited from class com.consol.citrus.channel.ChannelProducer

getDestinationChannel, getDestinationChannelName, getName, resolveChannelName

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.consol.citrus.messaging.Consumer

getName

Constructor Detail

ChannelSyncProducer

public ChannelSyncProducer(String name,
                           ChannelSyncEndpointConfiguration endpointConfiguration)

Default constructor using endpoint configuration.

Parameters:

name -

endpointConfiguration -

Method Detail

send

public void send(Message message,
                 TestContext context)

Description copied from interface: Producer

Sends the message.

Specified by:

send in interface Producer

Overrides:

send in class ChannelProducer

Parameters:

message - the message object to send.

receive

public Message receive(TestContext context)

Description copied from interface: Consumer

Receive message with default timeout.

Specified by:

receive in interface Consumer

Returns:

receive

public Message receive(String selector,
                       TestContext context)

Description copied from interface: SelectiveConsumer

Receive message with a message selector and default timeout.

Specified by:

receive in interface SelectiveConsumer

Returns:

receive

public Message receive(TestContext context,
                       long timeout)

Description copied from interface: Consumer

Receive message with a given timeout.

Specified by:

receive in interface Consumer

Returns:

receive

public Message receive(String selector,
                       TestContext context,
                       long timeout)

Description copied from interface: SelectiveConsumer

Receive message with a message selector and a receive timeout.

Specified by:

receive in interface SelectiveConsumer

timeout - @return

getCorrelationManager

public CorrelationManager<Message> getCorrelationManager()

Gets the correlation manager.

Returns:

setCorrelationManager

public void setCorrelationManager(CorrelationManager<Message> correlationManager)

Sets the correlation manager.

Parameters:

correlationManager -