Class JmsMessagingTemplate

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<jakarta.jms.Destination>

org.springframework.messaging.core.AbstractMessageReceivingTemplate<jakarta.jms.Destination>

org.springframework.messaging.core.AbstractMessagingTemplate<jakarta.jms.Destination>

org.springframework.jms.core.JmsMessagingTemplate

All Implemented Interfaces:

InitializingBean, JmsMessageOperations, MessageReceivingOperations<jakarta.jms.Destination>, MessageRequestReplyOperations<jakarta.jms.Destination>, MessageSendingOperations<jakarta.jms.Destination>

public class JmsMessagingTemplate
extends AbstractMessagingTemplate<jakarta.jms.Destination>
implements JmsMessageOperations, InitializingBean

An implementation of JmsMessageOperations, as a wrapper on top of Spring's traditional JmsTemplate. Aligned with the spring-messaging module and GenericMessagingTemplate.

Note: Operations in this interface throw MessagingException instead of the JMS-specific JmsException, aligning with the spring-messaging module and its other client operation handles.

Since:

4.1

Author:

Stephane Nicoll, Juergen Hoeller

See Also:

• JmsTemplate
• JmsClient

Field Summary

Fields inherited from class AbstractMessageSendingTemplate

CONVERSION_HINT_HEADER, logger

Constructor Summary

Constructors

Constructor	Description
JmsMessagingTemplate()	Constructor for use with bean properties.
JmsMessagingTemplate(jakarta.jms.ConnectionFactory connectionFactory)	Create a JmsMessagingTemplate instance with the JMS ConnectionFactory to use, implicitly building a JmsTemplate based on it.
JmsMessagingTemplate(JmsOperations jmsTemplate)	Create a JmsMessagingTemplate instance with the JmsOperations to use.
JmsMessagingTemplate(JmsTemplate jmsTemplate)	Create a JmsMessagingTemplate instance with the JmsTemplate to use.

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()	Invoked by the containing BeanFactory after it has set all bean properties and satisfied BeanFactoryAware, ApplicationContextAware etc.
void	convertAndSend(Object payload, @Nullable Map<String,Object> headers, @Nullable MessagePostProcessor postProcessor)	Convert the given 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 given destination.
void	convertAndSend(String destinationName, Object payload)	Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message and send it to the given destination.
void	convertAndSend(String destinationName, Object payload, @Nullable Map<String,Object> headers)	Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers and send it to the given destination.
void	convertAndSend(String destinationName, Object payload, @Nullable Map<String,Object> headers, @Nullable MessagePostProcessor postProcessor)	Convert the given 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 given destination.
void	convertAndSend(String destinationName, Object payload, @Nullable MessagePostProcessor postProcessor)	Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message, apply the given post-processor, and send the resulting message to the given destination.
protected MessagingException	convertJmsException(JmsException ex)
protected @Nullable Message<?>	convertJmsMessage(@Nullable jakarta.jms.Message message)
<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(String destinationName, 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(String destinationName, Object request, Class<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor)	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(String destinationName, 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(String destinationName, 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 @Nullable Message<?>	doReceive(jakarta.jms.Destination destination)	Actually receive a message from the given destination.
protected @Nullable Message<?>	doReceive(String destinationName)
protected @Nullable Message<?>	doReceiveSelected(jakarta.jms.Destination destination, @Nullable String messageSelector)
protected @Nullable Message<?>	doReceiveSelected(String destinationName, @Nullable String messageSelector)
protected void	doSend(jakarta.jms.Destination destination, Message<?> message)	Actually send the given message to the given destination.
protected void	doSend(String destinationName, Message<?> message)
protected @Nullable Message<?>	doSendAndReceive(jakarta.jms.Destination destination, Message<?> requestMessage)	Actually send the given request message to the given destination and receive a reply message for it.
protected @Nullable Message<?>	doSendAndReceive(String destinationName, Message<?> requestMessage)
@Nullable jakarta.jms.ConnectionFactory	getConnectionFactory()	Return the ConnectionFactory that the underlying JmsTemplate uses.
@Nullable String	getDefaultDestinationName()	Return the configured default destination name.
MessageConverter	getJmsMessageConverter()	Return the MessageConverter to use to convert a Message to and from a Message.
@Nullable JmsTemplate	getJmsTemplate()	Return the configured JmsTemplate.
protected String	getRequiredDefaultDestinationName()
@Nullable Message<?>	receive()	Receive a message from a default destination.
@Nullable Message<?>	receive(String destinationName)	Receive a message from the given destination.
<T> @Nullable T	receiveAndConvert(Class<T> targetClass)	Receive a message from a default destination and convert its payload to the specified target class.
<T> @Nullable T	receiveAndConvert(String destinationName, Class<T> targetClass)	Receive a message from the given destination and convert its payload to the specified target class.
@Nullable Message<?>	receiveSelected(jakarta.jms.Destination destination, @Nullable String messageSelector)	Receive a message from the given destination.
@Nullable Message<?>	receiveSelected(@Nullable String messageSelector)	Receive a message from the default destination.
@Nullable Message<?>	receiveSelected(String destinationName, @Nullable String messageSelector)	Receive a message from the given destination.
<T> @Nullable T	receiveSelectedAndConvert(jakarta.jms.Destination destination, @Nullable String messageSelector, Class<T> targetClass)	Receive a message from the given destination and convert its payload to the specified target class.
<T> @Nullable T	receiveSelectedAndConvert(@Nullable String messageSelector, Class<T> targetClass)	Receive a message from the default destination and convert its payload to the specified target class.
<T> @Nullable T	receiveSelectedAndConvert(String destinationName, @Nullable String messageSelector, Class<T> targetClass)	Receive a message from the given destination and convert its payload to the specified target class.
void	send(String destinationName, Message<?> message)	Send a message to the given destination.
void	send(Message<?> message)	Send a message to a default destination.
@Nullable Message<?>	sendAndReceive(String destinationName, 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.
void	setConnectionFactory(jakarta.jms.ConnectionFactory connectionFactory)	Set the ConnectionFactory to use for the underlying JmsTemplate.
void	setDefaultDestinationName(@Nullable String defaultDestinationName)	Configure the default destination name to use in send methods that don't have a destination argument.
void	setJmsMessageConverter(MessageConverter jmsMessageConverter)	Set the MessageConverter to use to convert a Message to and from a Message.
void	setJmsTemplate(@Nullable JmsTemplate jmsTemplate)	Set the JmsTemplate to use.

Methods inherited from class AbstractMessagingTemplate

convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive

Methods inherited from class AbstractMessageReceivingTemplate

doConvert, receive, receiveAndConvert

Methods inherited from class AbstractMessageSendingTemplate

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

Methods inherited from class Object

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

Methods inherited from interface MessageReceivingOperations

receive, receiveAndConvert

Methods inherited from interface MessageRequestReplyOperations

convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive

Methods inherited from interface MessageSendingOperations

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send

Constructor Details

JmsMessagingTemplate

public JmsMessagingTemplate()

Constructor for use with bean properties. Requires setConnectionFactory(ConnectionFactory) or setJmsTemplate(JmsTemplate) to be called.

JmsMessagingTemplate

public JmsMessagingTemplate(jakarta.jms.ConnectionFactory connectionFactory)

Create a JmsMessagingTemplate instance with the JMS ConnectionFactory to use, implicitly building a JmsTemplate based on it.

Since:

4.1.2

JmsMessagingTemplate

public JmsMessagingTemplate(JmsTemplate jmsTemplate)

Create a JmsMessagingTemplate instance with the JmsTemplate to use.

JmsMessagingTemplate

public JmsMessagingTemplate(JmsOperations jmsTemplate)

Create a JmsMessagingTemplate instance with the JmsOperations to use.

Since:

7.0

Method Details

setConnectionFactory

public void setConnectionFactory(jakarta.jms.ConnectionFactory connectionFactory)

Set the ConnectionFactory to use for the underlying JmsTemplate.

Since:

4.1.2

getConnectionFactory

public @Nullable jakarta.jms.ConnectionFactory getConnectionFactory()

Return the ConnectionFactory that the underlying JmsTemplate uses.

Since:

4.1.2

setJmsTemplate

public void setJmsTemplate(@Nullable JmsTemplate jmsTemplate)

Set the JmsTemplate to use.

getJmsTemplate

public @Nullable JmsTemplate getJmsTemplate()

Return the configured JmsTemplate.

setJmsMessageConverter

public void setJmsMessageConverter(MessageConverter jmsMessageConverter)

Set the MessageConverter to use to convert a Message to and from a Message.

By default, a MessagingMessageConverter is defined using a SimpleMessageConverter to convert the payload of the message.

Consider configuring a MessagingMessageConverter with a different payload converter for more advanced scenarios.

See Also:

• MessagingMessageConverter

getJmsMessageConverter

public MessageConverter getJmsMessageConverter()

Return the MessageConverter to use to convert a Message to and from a Message.

setDefaultDestinationName

public void setDefaultDestinationName(@Nullable String defaultDestinationName)

Configure the default destination name to use in send methods that don't have a destination argument. If a default destination is not configured, send methods without a destination argument will raise an exception if invoked.

See Also:

• AbstractMessageSendingTemplate.setDefaultDestination(Object)

getDefaultDestinationName

public @Nullable String getDefaultDestinationName()

Return the configured default destination name.

afterPropertiesSet

public void afterPropertiesSet()

Description copied from interface: InitializingBean

Invoked by the containing BeanFactory after it has set all bean properties and satisfied BeanFactoryAware, ApplicationContextAware etc.

This method allows the bean instance to perform validation of its overall configuration and final initialization when all bean properties have been set.

Specified by:

afterPropertiesSet in interface InitializingBean

send

public void send(Message<?> message)
          throws MessagingException

Description copied from interface: MessageSendingOperations

Send a message to a default destination.

Specified by:

send in interface MessageSendingOperations<jakarta.jms.Destination>

Overrides:

send in class AbstractMessageSendingTemplate<jakarta.jms.Destination>

Parameters:

message - the message to send

Throws:

MessagingException

convertAndSend

public void convertAndSend(Object payload,
 @Nullable Map<String,Object> headers,
 @Nullable MessagePostProcessor postProcessor)
                    throws MessagingException

Description copied from interface: MessageSendingOperations

Convert the given 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 given destination.

Specified by:

convertAndSend in interface MessageSendingOperations<jakarta.jms.Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<jakarta.jms.Destination>

Parameters:

payload - the Object to use as payload

headers - the headers for the message to send

postProcessor - the post-processor to apply to the message

Throws:

MessagingException

send

public void send(String destinationName,
 Message<?> message)
          throws MessagingException

Description copied from interface: JmsMessageOperations

Send a message to the given destination.

Specified by:

send in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

message - the message to send

Throws:

MessagingException

convertAndSend

public void convertAndSend(String destinationName,
 Object payload)
                    throws MessagingException

Description copied from interface: JmsMessageOperations

Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message and send it to the given destination.

Specified by:

convertAndSend in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

payload - the Object to use as payload

Throws:

MessagingException

convertAndSend

public void convertAndSend(String destinationName,
 Object payload,
 @Nullable Map<String,Object> headers)
                    throws MessagingException

Description copied from interface: JmsMessageOperations

Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers and send it to the given destination.

Specified by:

convertAndSend in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

payload - the Object to use as payload

headers - the headers for the message to send

Throws:

MessagingException

convertAndSend

public void convertAndSend(String destinationName,
 Object payload,
 @Nullable MessagePostProcessor postProcessor)
                    throws MessagingException

Description copied from interface: JmsMessageOperations

Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message, apply the given post-processor, and send the resulting message to the given destination.

Specified by:

convertAndSend in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

payload - the Object to use as payload

postProcessor - the post-processor to apply to the message

Throws:

MessagingException

convertAndSend

public void convertAndSend(String destinationName,
 Object payload,
 @Nullable Map<String,Object> headers,
 @Nullable MessagePostProcessor postProcessor)
                    throws MessagingException

Description copied from interface: JmsMessageOperations

Convert the given 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 given destination.

Specified by:

convertAndSend in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

payload - the Object to use as payload

headers - the headers for the message to send

postProcessor - the post-processor to apply to the message

Throws:

MessagingException

receive

public @Nullable Message<?> receive()
                             throws MessagingException

Description copied from interface: MessageReceivingOperations

Receive a message from a default destination.

Specified by:

receive in interface MessageReceivingOperations<jakarta.jms.Destination>

Overrides:

receive in class AbstractMessageReceivingTemplate<jakarta.jms.Destination>

Returns:

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

Throws:

MessagingException

receiveAndConvert

public <T> @Nullable T receiveAndConvert(Class<T> targetClass)
                                  throws MessagingException

Description copied from interface: MessageReceivingOperations

Receive a message from a default destination and convert its payload to the specified target class.

Specified by:

receiveAndConvert in interface MessageReceivingOperations<jakarta.jms.Destination>

Overrides:

receiveAndConvert in class AbstractMessageReceivingTemplate<jakarta.jms.Destination>

Parameters:

targetClass - the target class to convert the payload to

Returns:

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

Throws:

MessagingException

receive

public @Nullable Message<?> receive(String destinationName)
                             throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the given destination.

Specified by:

receive in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

Returns:

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

Throws:

MessagingException

receiveAndConvert

public <T> @Nullable T receiveAndConvert(String destinationName,
 Class<T> targetClass)
                                  throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the given destination and convert its payload to the specified target class.

Specified by:

receiveAndConvert in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

targetClass - the target class to convert the payload to

Returns:

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

Throws:

MessagingException

receiveSelected

public @Nullable Message<?> receiveSelected(@Nullable String messageSelector)
                                     throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the default destination.

Specified by:

receiveSelected in interface JmsMessageOperations

Parameters:

messageSelector - the JMS message selector expression (or null if none). See the JMS specification for a detailed definition of selector expressions.

Returns:

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

Throws:

MessagingException

receiveSelected

public @Nullable Message<?> receiveSelected(jakarta.jms.Destination destination,
 @Nullable String messageSelector)
                                     throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the given destination.

Specified by:

receiveSelected in interface JmsMessageOperations

Parameters:

destination - the target destination

messageSelector - the JMS message selector expression (or null if none). See the JMS specification for a detailed definition of selector expressions.

Returns:

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

Throws:

MessagingException

receiveSelected

public @Nullable Message<?> receiveSelected(String destinationName,
 @Nullable String messageSelector)
                                     throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the given destination.

Specified by:

receiveSelected in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

messageSelector - the JMS message selector expression (or null if none). See the JMS specification for a detailed definition of selector expressions.

Returns:

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

Throws:

MessagingException

receiveSelectedAndConvert

public <T> @Nullable T receiveSelectedAndConvert(@Nullable String messageSelector,
 Class<T> targetClass)
                                          throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the default destination and convert its payload to the specified target class.

Specified by:

receiveSelectedAndConvert in interface JmsMessageOperations

Parameters:

messageSelector - the JMS message selector expression (or null if none). See the JMS specification for a detailed definition of selector expressions.

targetClass - the target class to convert the payload to

Returns:

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

Throws:

MessagingException

receiveSelectedAndConvert

public <T> @Nullable T receiveSelectedAndConvert(jakarta.jms.Destination destination,
 @Nullable String messageSelector,
 Class<T> targetClass)
                                          throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the given destination and convert its payload to the specified target class.

Specified by:

receiveSelectedAndConvert in interface JmsMessageOperations

Parameters:

destination - the target destination

messageSelector - the JMS message selector expression (or null if none). See the JMS specification for a detailed definition of selector expressions.

targetClass - the target class to convert the payload to

Returns:

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

Throws:

MessagingException

receiveSelectedAndConvert

public <T> @Nullable T receiveSelectedAndConvert(String destinationName,
 @Nullable String messageSelector,
 Class<T> targetClass)
                                          throws MessagingException

Description copied from interface: JmsMessageOperations

Receive a message from the given destination and convert its payload to the specified target class.

Specified by:

receiveSelectedAndConvert in interface JmsMessageOperations

Parameters:

destinationName - the name of the target destination

messageSelector - the JMS message selector expression (or null if none). See the JMS specification for a detailed definition of selector expressions.

targetClass - the target class to convert the payload to

Returns:

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

Throws:

MessagingException

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<jakarta.jms.Destination>

Overrides:

sendAndReceive in class AbstractMessagingTemplate<jakarta.jms.Destination>

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(String destinationName,
 Message<?> requestMessage)
                                    throws MessagingException

Description copied from interface: JmsMessageOperations

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

Specified by:

sendAndReceive in interface JmsMessageOperations

Parameters:

destinationName - the name of 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(String destinationName,
 Object request,
 Class<T> targetClass)
                                      throws MessagingException

Description copied from interface: JmsMessageOperations

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 JmsMessageOperations

Parameters:

destinationName - the name of 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,
 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<jakarta.jms.Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<jakarta.jms.Destination>

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(String destinationName,
 Object request,
 @Nullable Map<String,Object> headers,
 Class<T> targetClass)
                                      throws MessagingException

Description copied from interface: JmsMessageOperations

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 JmsMessageOperations

Parameters:

destinationName - the name of 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<jakarta.jms.Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<jakarta.jms.Destination>

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(String destinationName,
 Object request,
 Class<T> targetClass,
 @Nullable MessagePostProcessor requestPostProcessor)
                                      throws MessagingException

Description copied from interface: JmsMessageOperations

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 JmsMessageOperations

Parameters:

destinationName - the name of the target destination

request - payload for the request message to send

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

requestPostProcessor - 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(String destinationName,
 Object request,
 @Nullable Map<String,Object> headers,
 Class<T> targetClass,
 @Nullable MessagePostProcessor postProcessor)
                                      throws MessagingException

Description copied from interface: JmsMessageOperations

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 JmsMessageOperations

Parameters:

destinationName - the name of 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

doSend

protected void doSend(jakarta.jms.Destination destination,
 Message<?> message)

Description copied from class: AbstractMessageSendingTemplate

Actually send the given message to the given destination.

Specified by:

doSend in class AbstractMessageSendingTemplate<jakarta.jms.Destination>

Parameters:

destination - the target destination

message - the message to send

doSend

protected void doSend(String destinationName,
 Message<?> message)

doReceive

protected @Nullable Message<?> doReceive(jakarta.jms.Destination destination)

Description copied from class: AbstractMessageReceivingTemplate

Actually receive a message from the given destination.

Specified by:

doReceive in class AbstractMessageReceivingTemplate<jakarta.jms.Destination>

Parameters:

destination - the target destination

Returns:

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

doReceive

protected @Nullable Message<?> doReceive(String destinationName)

doReceiveSelected

protected @Nullable Message<?> doReceiveSelected(jakarta.jms.Destination destination,
 @Nullable String messageSelector)

doReceiveSelected

protected @Nullable Message<?> doReceiveSelected(String destinationName,
 @Nullable String messageSelector)

doSendAndReceive

protected @Nullable Message<?> doSendAndReceive(jakarta.jms.Destination destination,
 Message<?> requestMessage)

Description copied from class: AbstractMessagingTemplate

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

Specified by:

doSendAndReceive in class AbstractMessagingTemplate<jakarta.jms.Destination>

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

doSendAndReceive

protected @Nullable Message<?> doSendAndReceive(String destinationName,
 Message<?> requestMessage)

getRequiredDefaultDestinationName

protected String getRequiredDefaultDestinationName()

convertJmsMessage

protected @Nullable Message<?> convertJmsMessage(@Nullable jakarta.jms.Message message)

convertJmsException

protected MessagingException convertJmsException(JmsException ex)