我正在探索jmsTemplate实现,并且遇到了问题。可以将JMSMessageId手动应用于消息,但是回调返回不同的MessageId。

样例代码:

log.debug("Sending request " + jmsMessageId);
final AtomicReference<Message> msg = new AtomicReference<>();
jmsTemplate.send(destinationQueue,
                session -> {
                    Message message = session.createTextMessage(body);
                    message.setJMSMessageID(jmsMessageId);
                    msg.set(message);
                    return message;
                });
log.debug("Request sent " + msg.get().getJMSMessageID());


输出为:

 2019-05-14 15:36:41.308 DEBUG Sending request 2136b3c2-71c7-437a-892f-5e72d27a54f1
 2019-05-14 15:36:41.487 DEBUG Request sent ID:414d51205445535420202020202020204be2be5c02e71527


我期望两个ID相同。
由于IBM提供的文档:

JMS_IBM_MQMD_MsgId属性将覆盖JMSMessageID属性的JMS缺省处理。当服务集成将消息转换为WebSphere MQ格式时,服务集成将检查是否已显式设置JMS_IBM_MQMD_MsgId属性。如果是这样,服务集成会将MQMD MsgId字段设置为此值(byte []),并替换JMS分配给消息的JMSMessageID的唯一值。

因此,不应该重写显式定义的MsgId,而应该对其进行编码?我的配置中是否缺少某些东西,或者这是正常现象?

最佳答案

setJMSMessageId不执行任何操作-从the javadocs开始。


  JMS提供程序仅在发送消息时使用此方法设置此字段。客户端不能使用此消息来配置消息ID。此方法是公共的,以允许JMS提供程序在发送其实现不是其自己的消息时设置此字段。


(我的重点)。

无论如何,这句话与您正在做的事情是相反的。


  JMS_IBM_MQMD_MsgId属性将覆盖JMSMessageID属性的JMS缺省处理。 ...


即您必须设置JMS_IBM_MQMD_MsgId属性,它将覆盖生成的JMSMessageID

关于java - Spring JmsTemplate.setMessageId被覆盖,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/56135309/

10-12 00:26