com.consol.citrus.channel

Class ChannelSyncConsumer

java.lang.Object

com.consol.citrus.messaging.AbstractMessageConsumer

com.consol.citrus.messaging.AbstractSelectiveMessageConsumer

com.consol.citrus.channel.ChannelConsumer

com.consol.citrus.channel.ChannelSyncConsumer

All Implemented Interfaces:

Consumer, Producer, ReplyProducer, SelectiveConsumer

public class ChannelSyncConsumer
extends ChannelConsumer
implements ReplyProducer

Since:

1.4

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
ChannelSyncConsumer(String name, ChannelSyncEndpointConfiguration endpointConfiguration) Default constructor using emdpoint configuration.

Method Summary

Modifier and Type	Method and Description
CorrelationManager<org.springframework.messaging.MessageChannel>	getCorrelationManager() Gets the correlation manager.
Message	receive(String selector, TestContext context, long timeout) Receive message with a message selector and a receive timeout.
void	saveReplyMessageChannel(Message receivedMessage, TestContext context) Store reply message channel.
void	send(Message message, TestContext context) Sends the message.
void	setCorrelationManager(CorrelationManager<org.springframework.messaging.MessageChannel> correlationManager) Sets the correlation manager.

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

getDestinationChannel, getDestinationChannelName, resolveChannelName

Methods inherited from class com.consol.citrus.messaging.AbstractSelectiveMessageConsumer

receive, receive

Methods inherited from class com.consol.citrus.messaging.AbstractMessageConsumer

getName, receive

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.Producer

getName

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

getName, receive

Constructor Detail

ChannelSyncConsumer

public ChannelSyncConsumer(String name,
                           ChannelSyncEndpointConfiguration endpointConfiguration)

Default constructor using emdpoint configuration.

Parameters:

name -

endpointConfiguration -

Method Detail

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

Overrides:

receive in class ChannelConsumer

timeout - @return

send

public void send(Message message,
                 TestContext context)

Description copied from interface: Producer

Sends the message.

Specified by:

send in interface Producer

Parameters:

message - the message object to send.

saveReplyMessageChannel

public void saveReplyMessageChannel(Message receivedMessage,
                                    TestContext context)

Store reply message channel.

Parameters:

receivedMessage -

context -

getCorrelationManager

public CorrelationManager<org.springframework.messaging.MessageChannel> getCorrelationManager()

Gets the correlation manager.

Returns:

setCorrelationManager

public void setCorrelationManager(CorrelationManager<org.springframework.messaging.MessageChannel> correlationManager)

Sets the correlation manager.

Parameters:

correlationManager -