发送消息
JmsTemplate 包含许多方便的发送消息方法。一些发送方法使用 jakarta.jms.Destination 对象指定目的地,另一些则使用 JNDI 查找中的 String 指定目的地。不带目的地参数的 send 方法使用默认目的地。以下示例使用 MessageCreator 回调从提供的 Session 对象创建文本消息:
include-code::./JmsQueueSender[]
在前面的示例中,JmsTemplate 通过传递 ConnectionFactory 的引用来构造。作为替代方案,提供了一个零参数构造函数和 connectionFactory,可用于以 JavaBean 样式(使用 BeanFactory 或纯 Java 代码)构造实例。或者,考虑从 Spring 的 JmsGatewaySupport 方便基类派生,该类为 JMS 配置提供了预构建的 bean 属性。
send(String destinationName, MessageCreator creator) 方法允许您使用目的地的字符串名称发送消息。如果这些名称在 JNDI 中注册,则应将模板的 destinationResolver 属性设置为 JndiDestinationResolver 的实例。
如果您创建了 JmsTemplate 并指定了默认目的地,则 send(MessageCreator c) 会向该目的地发送消息。
使用 JMS 消息转换器
为了方便发送领域模型对象,JmsTemplate 具有各种发送方法,这些方法将 Java 对象作为消息数据内容的一个参数。JmsTemplate 中重载的 convertAndSend() 和 receiveAndConvert() 方法将转换过程委托给 MessageConverter 接口的实例。此接口定义了一个简单的契约,用于在 Java 对象和 JMS 消息之间进行转换。默认实现 (SimpleMessageConverter) 支持 String 和 TextMessage、byte[] 和 BytesMessage 以及 java.util.Map 和 MapMessage 之间的转换。通过使用转换器,您和您的应用程序代码可以专注于通过 JMS 发送或接收的业务对象,而无需关心它如何表示为 JMS 消息的细节。
沙箱目前包含一个 MapMessageConverter,它使用反射在 JavaBean 和 MapMessage 之间进行转换。您可能自己实现的其他流行实现选择是使用现有 XML 编组包(例如 JAXB 或 XStream)创建表示对象的 TextMessage 的转换器。
为了适应设置消息的属性、标头和正文,这些不能通用地封装在转换器类中,MessagePostProcessor 接口允许您在消息转换后但在发送之前访问该消息。以下示例展示了在 java.util.Map 转换为消息后如何修改消息标头和属性:
这将生成以下形式的消息:
MapMessage={ Header={ ... standard headers ... CorrelationID={123-00001} } Properties={ AccountID={Integer:1234} } Fields={ Name={String:Mark} Age={Integer:47} } }
|
这种 JMS 特定的 |