向 MQ 发送消息时如何删除默认 Spring JMS 模板 headers?
How to remove default Spring JMS Template headers when sending a message to an MQ?
使用 Java/Spring 与 WebSphere MQ 交互并尝试向其发送消息,Spring 不断向其中添加以下 header 信息:
RFH Ì ¸MQSTR ¸ <mcd><Msd>jms_text</Msd></mcd> <jms><Dst>queue:///MY.QUEUE.INFORMATION.TEST</Dst><Rto>queue:///MY.QUEUE.INFORMATION.TEST</Rto><Tms>123456789</Tms><Dlv>2</Dlv></jms>BEGINNING_OF_MY_PAYLOAD
如何删除所有内容并只发送我的负载?可以将上面代码段中的有效载荷称为 BEGINNING_OF_MY_PAYLOAD
.
这是我正在使用的函数:
public void sendMessage(final String text) {
this.jmsTemplate.send(new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
Message message = session.createTextMessage(text);
destination = session.createQueue("MY.QUEUE.INFORMATION.TEST");
springJmsConsumer.setDestination(destination);
message.setJMSReplyTo(destination);
return message;
}
});
}
想通了。任何时候我们想要从发送到 WebSphere MQ 的 Spring JMS 消息中删除 headers,请始终使用以下内容:
this.jmsTemplate.convertAndSend("queue:///YOUR.QUEUE.NAME.HERE?targetClient=1", text);
所以现在我的函数看起来像:
public void send(String text) {
this.jmsTemplate.convertAndSend("queue:///MY.QUEUE.INFORMATION.TEST?targetClient=1", text);
}
使用 Java/Spring 与 WebSphere MQ 交互并尝试向其发送消息,Spring 不断向其中添加以下 header 信息:
RFH Ì ¸MQSTR ¸ <mcd><Msd>jms_text</Msd></mcd> <jms><Dst>queue:///MY.QUEUE.INFORMATION.TEST</Dst><Rto>queue:///MY.QUEUE.INFORMATION.TEST</Rto><Tms>123456789</Tms><Dlv>2</Dlv></jms>BEGINNING_OF_MY_PAYLOAD
如何删除所有内容并只发送我的负载?可以将上面代码段中的有效载荷称为 BEGINNING_OF_MY_PAYLOAD
.
这是我正在使用的函数:
public void sendMessage(final String text) {
this.jmsTemplate.send(new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
Message message = session.createTextMessage(text);
destination = session.createQueue("MY.QUEUE.INFORMATION.TEST");
springJmsConsumer.setDestination(destination);
message.setJMSReplyTo(destination);
return message;
}
});
}
想通了。任何时候我们想要从发送到 WebSphere MQ 的 Spring JMS 消息中删除 headers,请始终使用以下内容:
this.jmsTemplate.convertAndSend("queue:///YOUR.QUEUE.NAME.HERE?targetClient=1", text);
所以现在我的函数看起来像:
public void send(String text) {
this.jmsTemplate.convertAndSend("queue:///MY.QUEUE.INFORMATION.TEST?targetClient=1", text);
}