Class AbstractMessagingTemplate<D>

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<D>

org.springframework.messaging.core.AbstractMessageReceivingTemplate<D>

org.springframework.messaging.core.AbstractMessagingTemplate<D>

Type Parameters:

D - the destination type

All Implemented Interfaces:

MessageReceivingOperations<D>, MessageRequestReplyOperations<D>, MessageSendingOperations<D>

Direct Known Subclasses:

AbstractDestinationResolvingMessagingTemplate, JmsMessagingTemplate

public abstract class AbstractMessagingTemplate<D>
extends AbstractMessageReceivingTemplate<D>
implements MessageRequestReplyOperations<D>

An extension of AbstractMessageReceivingTemplate that adds support for request-reply style operations as defined by MessageRequestReplyOperations.

Since:

4.0

Author:

Mark Fisher, Rossen Stoyanchev, Stephane Nicoll, Juergen Hoeller

Field Summary

Fields inherited from class AbstractMessageSendingTemplate

CONVERSION_HINT_HEADER, logger

Constructor Summary

Constructors

Constructor	Description
AbstractMessagingTemplate()

Method Summary

Modifier and Type	Method	Description
<T> @Nullable T	convertSendAndReceive(D destination, Object request, Class<T> targetClass)	Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message to the given destination, receive the reply and convert its body of the specified target class.
<T> @Nullable T	convertSendAndReceive(D destination, Object request, Class<T> targetClass, @Nullable MessagePostProcessor postProcessor)	Convert the given request Object to serialized form, possibly using a MessageConverter, apply the given post-processor and send the resulting Message to the given destination, receive the reply and convert its body of the given target class.
<T> @Nullable T	convertSendAndReceive(D destination, Object request, @Nullable Map<String,Object> headers, Class<T> targetClass)	Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message with the given headers, to the specified destination, receive the reply and convert its body of the specified target class.
<T> @Nullable T	convertSendAndReceive(D destination, Object request, @Nullable Map<String,Object> headers, Class<T> targetClass, @Nullable MessagePostProcessor postProcessor)	Convert the given request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post-processor and send the resulting Message to the specified destination, receive the reply and convert its body of the given target class.
<T> @Nullable T	convertSendAndReceive(Object request, Class<T> targetClass)	Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message to a default destination, receive the reply and convert its body of the specified target class.
<T> @Nullable T	convertSendAndReceive(Object request, Class<T> targetClass, @Nullable MessagePostProcessor postProcessor)	Convert the given request Object to serialized form, possibly using a MessageConverter, apply the given post-processor and send the resulting Message to a default destination, receive the reply and convert its body of the given target class.
<T> @Nullable T	convertSendAndReceive(Object request, @Nullable Map<String,Object> headers, Class<T> targetClass)	Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message with the given headers, to the specified destination, receive the reply and convert its body of the specified target class.
<T> @Nullable T	convertSendAndReceive(Object request, @Nullable Map<String,Object> headers, Class<T> targetClass, @Nullable MessagePostProcessor postProcessor)	Convert the given request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post-processor and send the resulting Message to the specified destination, receive the reply and convert its body of the given target class.
protected abstract @Nullable Message<?>	doSendAndReceive(D destination, Message<?> requestMessage)	Actually send the given request message to the given destination and receive a reply message for it.
@Nullable Message<?>	sendAndReceive(D destination, Message<?> requestMessage)	Send a request message and receive the reply from the given destination.
@Nullable Message<?>	sendAndReceive(Message<?> requestMessage)	Send a request message and receive the reply from a default destination.

Methods inherited from class AbstractMessageReceivingTemplate

doConvert, doReceive, receive, receive, receiveAndConvert, receiveAndConvert

Methods inherited from class AbstractMessageSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, doSend, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter

Methods inherited from class Object

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

Constructor Details

AbstractMessagingTemplate

public AbstractMessagingTemplate()

Method Details

sendAndReceive

public @Nullable Message<?> sendAndReceive(Message<?> requestMessage)
                                    throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Send a request message and receive the reply from a default destination.

Specified by:

sendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

requestMessage - the message to send

Returns:

the reply, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

sendAndReceive

public @Nullable Message<?> sendAndReceive(D destination,
 Message<?> requestMessage)
                                    throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Send a request message and receive the reply from the given destination.

Specified by:

sendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

destination - the target destination

requestMessage - the message to send

Returns:

the reply, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(Object request,
 Class<T> targetClass)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message to a default destination, receive the reply and convert its body of the specified target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

request - payload for the request message to send

targetClass - the target type to convert the payload of the reply to

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(D destination,
 Object request,
 Class<T> targetClass)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message to the given destination, receive the reply and convert its body of the specified target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

destination - the target destination

request - payload for the request message to send

targetClass - the target type to convert the payload of the reply to

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(Object request,
 @Nullable Map<String,Object> headers,
 Class<T> targetClass)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message with the given headers, to the specified destination, receive the reply and convert its body of the specified target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

request - payload for the request message to send

headers - the headers for the request message to send

targetClass - the target type to convert the payload of the reply to

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(D destination,
 Object request,
 @Nullable Map<String,Object> headers,
 Class<T> targetClass)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message with the given headers, to the specified destination, receive the reply and convert its body of the specified target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

destination - the target destination

request - payload for the request message to send

headers - the headers for the request message to send

targetClass - the target type to convert the payload of the reply to

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(Object request,
 Class<T> targetClass,
 @Nullable MessagePostProcessor postProcessor)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, apply the given post-processor and send the resulting Message to a default destination, receive the reply and convert its body of the given target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

request - payload for the request message to send

targetClass - the target type to convert the payload of the reply to

postProcessor - post-process to apply to the request message

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(D destination,
 Object request,
 Class<T> targetClass,
 @Nullable MessagePostProcessor postProcessor)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, apply the given post-processor and send the resulting Message to the given destination, receive the reply and convert its body of the given target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

destination - the target destination

request - payload for the request message to send

targetClass - the target type to convert the payload of the reply to

postProcessor - post-process to apply to the request message

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(Object request,
 @Nullable Map<String,Object> headers,
 Class<T> targetClass,
 @Nullable MessagePostProcessor postProcessor)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post-processor and send the resulting Message to the specified destination, receive the reply and convert its body of the given target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

request - payload for the request message to send

targetClass - the target type to convert the payload of the reply to

postProcessor - post-process to apply to the request message

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

convertSendAndReceive

public <T> @Nullable T convertSendAndReceive(D destination,
 Object request,
 @Nullable Map<String,Object> headers,
 Class<T> targetClass,
 @Nullable MessagePostProcessor postProcessor)
                                      throws MessagingException

Description copied from interface: MessageRequestReplyOperations

Convert the given request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post-processor and send the resulting Message to the specified destination, receive the reply and convert its body of the given target class.

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<D>

Parameters:

destination - the target destination

request - payload for the request message to send

targetClass - the target type to convert the payload of the reply to

postProcessor - post-process to apply to the request message

Returns:

the payload of the reply message, possibly null if the message could not be received, for example due to a timeout

Throws:

MessagingException

doSendAndReceive

protected abstract @Nullable Message<?> doSendAndReceive(D destination,
 Message<?> requestMessage)

Actually send the given request message to the given destination and receive a reply message for it.

Parameters:

destination - the target destination

requestMessage - the message to send

Returns:

the received reply, possibly null if the message could not be received, for example due to a timeout