在一个事务中发送多个 jms 消息

Question

我必须向 2 个不同的队列（queue1 和 queue2）发送消息。但是，如果任何队列（queue1 或 queue2）的发送失败，我想回滚。

我的源代码如下所示。任何人都可以通过一些输入来解决这个问题。

  public void sendMessage(final Map<String, String> mapMessage) {

    jmsTemplate.send(queue1, session -> {
      MapMessage message = session.createMapMessage();
      Iterator<Entry<String, String>> it = mapMessage.entrySet().iterator();
      while (it.hasNext()) {
        Map.Entry<String, String> pair = it.next();
        message.setStringProperty(pair.getKey(), pair.getValue());
      }
      message.setJMSRedelivered(true);
      message.setJMSCorrelationID(UUID.randomUUID().toString().replaceAll("-", ""));
      return message;
    });

    jmsTemplate.send(queue2, session -> {
      MapMessage message = session.createMapMessage();
      Iterator<Entry<String, String>> it = mapMessage.entrySet().iterator();
      while (it.hasNext()) {
        Map.Entry<String, String> pair = it.next();
        message.setStringProperty(pair.getKey(), pair.getValue());
      }
      message.setJMSRedelivered(true);
      message.setJMSCorrelationID(UUID.randomUUID().toString().replaceAll("-", ""));
      return message;
    });

    }

Answer 1

在进入sendMessage方法之前开始交易，例如使用 @Transactional - 请参阅 Spring Framework Reference Manual.

在一个事务中发送多个 jms 消息

send multiple jms messages in one transaction

jms

jmstemplate

spring-jms