在Spring中创建临时JMS jms主题

Question

我正在尝试重构一些遗留代码以使用 Spring 处理与大型机服务的 jms 连接。我需要连接为大型机服务回复创建一个临时主题，并将其设置为消息中的 message.setJMSReplyTo(replyTo);，然后再发送消息。

谁能提供这方面的例子吗？我在文档中没有找到任何允许您访问低级别 jms 对象（例如会话或 TopicConnection）以创建临时主题的内容。

Answer 1

如果您需要使用 JmsTemplate 对 JMS API 进行低级访问，那么您需要使用 JmsTemplate 的 execute(...) 方法。其中最简单的是execute(SessionCallBack)，其中 SessionCallback 为您提供 JMS Session 对象。这样，您就可以调用 createTemporaryQueue() 或 createTemporaryTopic()。不过，您可能可以使用其他 execute() 方法之一为您完成一些初始工作，例如 这个。

Answer 2

我能够在 Spring Boot 应用程序中使用以下代码动态创建队列：

在 Application.java

@Bean 
public ConnectionFactory jmsFactory()
{
    ActiveMQConnectionFactory amq = new ActiveMQConnectionFactory()

    amq.setBrokerURL("tcp://somehost");

    return amq;
}

@Bean 
public JmsTemplate myJmsTemplate()
{
    JmsTemplate jmsTemplate = new JmsTemplate(jmsFactory());

    jmsTemplate.setPubSubDomain(false);
    return jmsTemplate;
}

然后在另一个动态创建队列的类中：

@Component
public class Foo {
    @Autowired
    private ConnectionFactory jmsFactory;

    public void someMethod () {
        DefaultMessageListenerContainer messageListener = new DefaultMessageListenerContainer();

        messageListener.setDestinationName("queueName");
        messageListener.setConnectionFactory(jmsFactory);
        messageListener.setMessageListener(new Consumer("queueName"));
        messageListener.setPubSubDomain(false);
        messageListener.initialize();
        messageListener.start();
    }
}