org.springframework.jms.core

Class JmsMessagingTemplate

java.lang.Object

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

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

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

org.springframework.jms.core.JmsMessagingTemplate

All Implemented Interfaces:

InitializingBean, JmsMessageOperations, MessageReceivingOperations<Destination>, MessageRequestReplyOperations<Destination>, MessageSendingOperations<Destination>

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

An implementation of JmsMessageOperations.

Since:

4.1

Author:

Stephane Nicoll, Juergen Hoeller

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	JmsMessagingTemplate.MessagingMessageCreator

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	defaultDestinationName
private MessageConverter	jmsMessageConverter
private JmsTemplate	jmsTemplate

Fields inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

CONVERSION_HINT_HEADER, logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Invoked by a BeanFactory after it has set all bean properties supplied (and satisfied BeanFactoryAware and ApplicationContextAware).
void	convertAndSend(java.lang.Object payload) Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message and send it to a default destination.
void	convertAndSend(java.lang.Object payload, 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 a default destination.
void	convertAndSend(java.lang.String destinationName, java.lang.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(java.lang.String destinationName, java.lang.Object payload, java.util.Map<java.lang.String,java.lang.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(java.lang.String destinationName, java.lang.Object payload, java.util.Map<java.lang.String,java.lang.Object> headers, 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(java.lang.String destinationName, java.lang.Object payload, 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 Message<?>	convertJmsMessage(javax.jms.Message message)
<T> T	convertSendAndReceive(java.lang.Object request, java.lang.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> T	convertSendAndReceive(java.lang.Object request, java.lang.Class<T> targetClass, 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> T	convertSendAndReceive(java.lang.String destinationName, java.lang.Object request, java.lang.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> T	convertSendAndReceive(java.lang.String destinationName, java.lang.Object request, java.lang.Class<T> targetClass, 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> T	convertSendAndReceive(java.lang.String destinationName, java.lang.Object request, java.util.Map<java.lang.String,java.lang.Object> headers, java.lang.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> T	convertSendAndReceive(java.lang.String destinationName, java.lang.Object request, java.util.Map<java.lang.String,java.lang.Object> headers, java.lang.Class<T> targetClass, 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.
private JmsMessagingTemplate.MessagingMessageCreator	createMessageCreator(Message<?> message)
protected Message<?>	doReceive(Destination destination) Actually receive a message from the given destination.
protected void	doSend(Destination destination, Message<?> message)
protected Message<?>	doSendAndReceive(Destination destination, Message<?> requestMessage)
ConnectionFactory	getConnectionFactory() Return the ConnectionFactory that the underlying JmsTemplate uses.
java.lang.String	getDefaultDestinationName() Return the configured default destination name.
MessageConverter	getJmsMessageConverter() Return the MessageConverter to use to convert a Message from the messaging to and from a javax.jms.Message.
JmsTemplate	getJmsTemplate() Return the configured JmsTemplate.
protected java.lang.String	getRequiredDefaultDestinationName()
Message<?>	receive() Receive a message from a default destination.
Message<?>	receive(java.lang.String destinationName) Receive a message from the given destination.
<T> T	receiveAndConvert(java.lang.Class<T> targetClass) Receive a message from a default destination and convert its payload to the specified target class.
<T> T	receiveAndConvert(java.lang.String destinationName, java.lang.Class<T> targetClass) Receive a message from the given destination and convert its payload to the specified target class.
void	send(Message<?> message) Send a message to a default destination.
void	send(java.lang.String destinationName, Message<?> message) Send a message to the given destination.
Message<?>	sendAndReceive(Message<?> requestMessage) Send a request message and receive the reply from a default destination.
Message<?>	sendAndReceive(java.lang.String destinationName, Message<?> requestMessage) Send a request message and receive the reply from the given destination.
void	setConnectionFactory(ConnectionFactory connectionFactory) Set the ConnectionFactory to use for the underlying JmsTemplate.
void	setDefaultDestinationName(java.lang.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 from the messaging to and from a javax.jms.Message.
void	setJmsTemplate(JmsTemplate jmsTemplate) Set the JmsTemplate to use.

Methods inherited from class org.springframework.messaging.core.AbstractMessageReceivingTemplate

doConvert

Methods inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

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

Methods inherited from class java.lang.Object

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

Field Detail

jmsTemplate

private JmsTemplate jmsTemplate

jmsMessageConverter

private MessageConverter jmsMessageConverter

defaultDestinationName

private java.lang.String defaultDestinationName

Constructor Detail

JmsMessagingTemplate

public JmsMessagingTemplate()

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

JmsMessagingTemplate

public JmsMessagingTemplate(ConnectionFactory connectionFactory)

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

Since:

4.1.2

Method Detail

setConnectionFactory

public void setConnectionFactory(ConnectionFactory connectionFactory)

Set the ConnectionFactory to use for the underlying JmsTemplate.

Since:

4.1.2

getConnectionFactory

public ConnectionFactory getConnectionFactory()

Return the ConnectionFactory that the underlying JmsTemplate uses.

Since:

4.1.2

setJmsTemplate

public void setJmsTemplate(JmsTemplate jmsTemplate)

Set the JmsTemplate to use.

getJmsTemplate

public JmsTemplate getJmsTemplate()

Return the configured JmsTemplate.

setJmsMessageConverter

public void setJmsMessageConverter(MessageConverter jmsMessageConverter)

Set the MessageConverter to use to convert a Message from the messaging to and from a javax.jms.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 from the messaging to and from a javax.jms.Message.

setDefaultDestinationName

public void setDefaultDestinationName(java.lang.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 java.lang.String getDefaultDestinationName()

Return the configured default destination name.

afterPropertiesSet

public void afterPropertiesSet()

Description copied from interface: InitializingBean

Invoked by a BeanFactory after it has set all bean properties supplied (and satisfied BeanFactoryAware and ApplicationContextAware).

This method allows the bean instance to perform initialization only possible when all bean properties have been set and to throw an exception in the event of misconfiguration.

Specified by:

afterPropertiesSet in interface InitializingBean

send

public void send(Message<?> message)

Description copied from interface: MessageSendingOperations

Send a message to a default destination.

Specified by:

send in interface MessageSendingOperations<Destination>

Overrides:

send in class AbstractMessageSendingTemplate<Destination>

Parameters:

message - the message to send

convertAndSend

public void convertAndSend(java.lang.Object payload)
                    throws MessagingException

Description copied from interface: MessageSendingOperations

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

Specified by:

convertAndSend in interface MessageSendingOperations<Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<Destination>

Parameters:

payload - the Object to use as payload

Throws:

MessagingException

convertAndSend

public void convertAndSend(java.lang.Object payload,
                           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, apply the given post processor, and send the resulting message to a default destination.

Specified by:

convertAndSend in interface MessageSendingOperations<Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<Destination>

Parameters:

payload - the Object to use as payload

postProcessor - the post processor to apply to the message

Throws:

MessagingException

send

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

Description copied from interface: MessageSendingOperations

Send a message to the given destination.

Specified by:

send in interface JmsMessageOperations

Specified by:

send in interface MessageSendingOperations<Destination>

Overrides:

send in class AbstractMessageSendingTemplate<Destination>

Parameters:

destinationName - the target destination

message - the message to send

Throws:

MessagingException

convertAndSend

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

Description copied from interface: MessageSendingOperations

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

Specified by:

convertAndSend in interface MessageSendingOperations<Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<Destination>

Parameters:

destinationName - the target destination

payload - the Object to use as payload

Throws:

MessagingException

convertAndSend

public void convertAndSend(java.lang.String destinationName,
                           java.lang.Object payload,
                           java.util.Map<java.lang.String,java.lang.Object> headers)
                    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 and send it to the given destination.

Specified by:

convertAndSend in interface JmsMessageOperations

Specified by:

convertAndSend in interface MessageSendingOperations<Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<Destination>

Parameters:

destinationName - the target destination

payload - the Object to use as payload

headers - headers for the message to send

Throws:

MessagingException

convertAndSend

public void convertAndSend(java.lang.String destinationName,
                           java.lang.Object payload,
                           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, apply the given post processor, and send the resulting message to the given destination.

Specified by:

convertAndSend in interface JmsMessageOperations

Specified by:

convertAndSend in interface MessageSendingOperations<Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<Destination>

Parameters:

destinationName - 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(java.lang.String destinationName,
                           java.lang.Object payload,
                           java.util.Map<java.lang.String,java.lang.Object> headers,
                           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 JmsMessageOperations

Specified by:

convertAndSend in interface MessageSendingOperations<Destination>

Overrides:

convertAndSend in class AbstractMessageSendingTemplate<Destination>

Parameters:

destinationName - the target destination

payload - the Object to use as payload

headers - headers for the message to send

postProcessor - the post processor to apply to the message

Throws:

MessagingException

receive

public Message<?> receive()

Description copied from interface: MessageReceivingOperations

Receive a message from a default destination.

Specified by:

receive in interface MessageReceivingOperations<Destination>

Overrides:

receive in class AbstractMessageReceivingTemplate<Destination>

Returns:

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

receiveAndConvert

public <T> T receiveAndConvert(java.lang.Class<T> targetClass)

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<Destination>

Overrides:

receiveAndConvert in class AbstractMessageReceivingTemplate<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

receive

public Message<?> receive(java.lang.String destinationName)
                   throws MessagingException

Description copied from interface: MessageReceivingOperations

Receive a message from the given destination.

Specified by:

receive in interface JmsMessageOperations

Specified by:

receive in interface MessageReceivingOperations<Destination>

Overrides:

receive in class AbstractMessageReceivingTemplate<Destination>

Parameters:

destinationName - 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> T receiveAndConvert(java.lang.String destinationName,
                               java.lang.Class<T> targetClass)
                        throws MessagingException

Description copied from interface: MessageReceivingOperations

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

Specified by:

receiveAndConvert in interface JmsMessageOperations

Specified by:

receiveAndConvert in interface MessageReceivingOperations<Destination>

Overrides:

receiveAndConvert in class AbstractMessageReceivingTemplate<Destination>

Parameters:

destinationName - 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

sendAndReceive

public Message<?> sendAndReceive(Message<?> requestMessage)

Description copied from interface: MessageRequestReplyOperations

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

Specified by:

sendAndReceive in interface MessageRequestReplyOperations<Destination>

Overrides:

sendAndReceive in class AbstractMessagingTemplate<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

sendAndReceive

public Message<?> sendAndReceive(java.lang.String destinationName,
                                 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 JmsMessageOperations

Specified by:

sendAndReceive in interface MessageRequestReplyOperations<Destination>

Overrides:

sendAndReceive in class AbstractMessagingTemplate<Destination>

Parameters:

destinationName - 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> T convertSendAndReceive(java.lang.String destinationName,
                                   java.lang.Object request,
                                   java.lang.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 JmsMessageOperations

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<Destination>

Parameters:

destinationName - 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> T convertSendAndReceive(java.lang.Object request,
                                   java.lang.Class<T> targetClass)

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<Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<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

convertSendAndReceive

public <T> T convertSendAndReceive(java.lang.String destinationName,
                                   java.lang.Object request,
                                   java.util.Map<java.lang.String,java.lang.Object> headers,
                                   java.lang.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 JmsMessageOperations

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<Destination>

Parameters:

destinationName - the target destination

request - payload for the request message to send

headers - 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> T convertSendAndReceive(java.lang.Object request,
                                   java.lang.Class<T> targetClass,
                                   MessagePostProcessor postProcessor)

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<Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<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

convertSendAndReceive

public <T> T convertSendAndReceive(java.lang.String destinationName,
                                   java.lang.Object request,
                                   java.lang.Class<T> targetClass,
                                   MessagePostProcessor requestPostProcessor)
                            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 JmsMessageOperations

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<Destination>

Parameters:

destinationName - 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> T convertSendAndReceive(java.lang.String destinationName,
                                   java.lang.Object request,
                                   java.util.Map<java.lang.String,java.lang.Object> headers,
                                   java.lang.Class<T> targetClass,
                                   MessagePostProcessor postProcessor)

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 JmsMessageOperations

Specified by:

convertSendAndReceive in interface MessageRequestReplyOperations<Destination>

Overrides:

convertSendAndReceive in class AbstractMessagingTemplate<Destination>

Parameters:

destinationName - 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

doSend

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

Specified by:

doSend in class AbstractMessageSendingTemplate<Destination>

doReceive

protected Message<?> doReceive(Destination destination)

Description copied from class: AbstractMessageReceivingTemplate

Actually receive a message from the given destination.

Specified by:

doReceive in class AbstractMessageReceivingTemplate<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

doSendAndReceive

protected Message<?> doSendAndReceive(Destination destination,
                                      Message<?> requestMessage)

Specified by:

doSendAndReceive in class AbstractMessagingTemplate<Destination>

createMessageCreator

private JmsMessagingTemplate.MessagingMessageCreator createMessageCreator(Message<?> message)

getRequiredDefaultDestinationName

protected java.lang.String getRequiredDefaultDestinationName()

convertJmsMessage

protected Message<?> convertJmsMessage(javax.jms.Message message)

convertJmsException

protected MessagingException convertJmsException(JmsException ex)