发送消息
这JmsTemplate包含许多发送消息的便捷方法。发送
methods 使用jakarta.jms.Destinationobject 和其他
使用String在 JNDI 查找中。这send方法
,则不设 destination 参数使用默认 destination。
以下示例使用MessageCreatorcallback 创建文本消息
提供Session对象:
import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.Queue;
import jakarta.jms.Session;
import org.springframework.jms.core.MessageCreator;
import org.springframework.jms.core.JmsTemplate;
public class JmsQueueSender {
private JmsTemplate jmsTemplate;
private Queue queue;
public void setConnectionFactory(ConnectionFactory cf) {
this.jmsTemplate = new JmsTemplate(cf);
}
public void setQueue(Queue queue) {
this.queue = queue;
}
public void simpleSend() {
this.jmsTemplate.send(this.queue, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage("hello queue world");
}
});
}
}
在前面的示例中,JmsTemplate是通过传递对ConnectionFactory.作为替代方案,零参数构造函数和connectionFactory提供,并可用于在
JavaBean 样式(使用BeanFactory或纯 Java 代码)。或者,考虑
派生自 Spring 的JmsGatewaySupportconvenience 基类,该基类提供
用于 JMS 配置的预构建 Bean 属性。
这send(String destinationName, MessageCreator creator)方法允许您发送
message 使用目标的字符串名称。如果这些名称已在 JNDI 中注册,则
您应该设置destinationResolver属性添加到JndiDestinationResolver.
如果您创建了JmsTemplate并指定了一个默认目标,send(MessageCreator c)向该目标发送消息。
使用消息转换器
为了方便发送域模型对象,JmsTemplate具有
各种 send 方法,这些方法将 Java 对象作为消息数据的参数
内容。重载方法convertAndSend()和receiveAndConvert()methods 中的JmsTemplate将转换过程委托给MessageConverter接口。此接口定义了一个简单的协定,用于在 Java 对象和
JMS 消息。默认实现 (SimpleMessageConverter) 支持转换
之间String和TextMessage,byte[]和BytesMessage和java.util.Map和MapMessage.通过使用转换器,您和您的应用程序代码可以专注于
业务对象,而不关心
有关如何将其表示为 JMS 消息的详细信息。
Sandbox 当前包括一个MapMessageConverter,它使用反射来转换
在 JavaBean 和MapMessage.您可能的其他常用实施选择
实现自己的方法是使用现有 XML 封送包(例如
JAXB 或 XStream) 创建一个TextMessage表示对象。
为了适应消息的属性、标头和正文的设置,这些设置不能是
通常封装在 Converter 类中,MessagePostProcessor接口
允许您在消息转换之后但在发送之前访问消息。这
以下示例显示了如何修改 Message 标头和java.util.Map转换为消息:
public void sendWithConversion() {
Map map = new HashMap();
map.put("Name", "Mark");
map.put("Age", new Integer(47));
jmsTemplate.convertAndSend("testQueue", map, new MessagePostProcessor() {
public Message postProcessMessage(Message message) throws JMSException {
message.setIntProperty("AccountID", 1234);
message.setJMSCorrelationID("123-00001");
return message;
}
});
}
这将生成以下形式的消息:
MapMessage={
Header={
... standard headers ...
CorrelationID={123-00001}
}
Properties={
AccountID={Integer:1234}
}
Fields={
Name={String:Mark}
Age={Integer:47}
}
}
用SessionCallback和ProducerCallback
虽然 send作涵盖了许多常见的使用场景,但有时您可能会
想要对 JMS 执行多个作Session或MessageProducer.这SessionCallback和ProducerCallback公开 JMSSession和Session /
MessageProducer对。这execute()方法JmsTemplate跑
这些回调方法。