com.consol.citrus.channel
Class SyncMessageChannelSender

java.lang.Object
  com.consol.citrus.channel.MessageChannelSender
      com.consol.citrus.channel.SyncMessageChannelSender

All Implemented Interfaces:

MessageSender, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware

public class SyncMessageChannelSender
extends MessageChannelSender

Synchronous message channel sender. After sending message action will listen for reply message. A ReplyMessageHandler may ask for this reply message and continue with message validation.

Author:

Christoph Deppisch

Nested Class Summary

Nested classes/interfaces inherited from interface com.consol.citrus.message.MessageSender

MessageSender.ErrorHandlingStrategy

Constructor Summary

SyncMessageChannelSender()

Method Summary

ReplyMessageCorrelator	getCorrelator() Get the reply message correlator.
ReplyMessageHandler	getReplyMessageHandler() Get the reply message handler.
long	getReplyTimeout() Get the reply timeout.
void	send(org.springframework.integration.Message<?> message) Sends the message.
void	setCorrelator(ReplyMessageCorrelator correlator) Set the reply message correlator.
void	setReplyMessageHandler(ReplyMessageHandler replyMessageHandler) Set the reply message handler
void	setReplyTimeout(long replyTimeout) Set the reply timeout.

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

getActor, getChannel, getChannelName, getChannelResolver, getDestinationChannel, getDestinationChannelName, getMessagingTemplate, resolveChannelName, setActor, setBeanFactory, setChannel, setChannelName, setChannelResolver, setMessagingTemplate

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncMessageChannelSender

public SyncMessageChannelSender()

Method Detail

send

public void send(org.springframework.integration.Message<?> message)

Description copied from interface: MessageSender

Sends the message.

Specified by:

send in interface MessageSender

Overrides:

send in class MessageChannelSender

Parameters:

message - the message object to send.

Throws:

CitrusRuntimeException

See Also:

MessageSender.send(org.springframework.integration.Message)

setReplyMessageHandler

public void setReplyMessageHandler(ReplyMessageHandler replyMessageHandler)

Set the reply message handler

Parameters:

replyMessageHandler - the replyMessageHandler to set

getReplyMessageHandler

public ReplyMessageHandler getReplyMessageHandler()

Get the reply message handler.

Returns:

the replyMessageHandler

setReplyTimeout

public void setReplyTimeout(long replyTimeout)

Set the reply timeout.

Parameters:

replyTimeout - the replyTimeout to set

getReplyTimeout

public long getReplyTimeout()

Get the reply timeout.

Returns:

the replyTimeout

setCorrelator

public void setCorrelator(ReplyMessageCorrelator correlator)

Set the reply message correlator.

Parameters:

correlator - the correlator to set

getCorrelator

public ReplyMessageCorrelator getCorrelator()

Get the reply message correlator.

Returns:

the correlator