0

我需要使用 RFH2 标头创建一条消息并将其注入 IBM MQ。请在下面找到消息是如何创建的。

def message = new MQMessage()
def rfh2 = new MQRFH2()
rfh2.setEncoding(CMQC.MQENC_NATIVE)
rfh2.setCodedCharSetId(CMQC.MQCCSI_INHERIT)
rfh2.setFormat("        ")
rfh2.setNameValueCCSID(1208)
rfh2.setFieldValue('mcd', 'Msd', 'jms_byte')
rfh2.setFieldValue('jms', 'Dst', 'queue:///myqueue')
rfh2.setFieldValue('jms', 'Pri', 0)
rfh2.setFieldValue('usr', 'Sender', 'mysender')
rfh2.write(message)

message.writeString('''${msgText}''')

但是，似乎标题内容不是放在标题中而是放在消息之前。请在下面找到一个示例：

带有使用 MQ Visual Edit 发送的消息的服务器日志

标题

 2020-04-21 11:07:59.913 DEBUG 48093 --- [DefaultMessageListenerContainer-2] 
 c.b.i.c.listeners.AbstractAgiListener    : Receive message on MQ with header : {someargs, 
 jms_destination=queue:///myqueue, someargs, Sender=mysender, someargs, jms_type=mcd://jms_byte,
 someargs}

信息

 <Document ...>...</Document>

服务器日志以及使用上述代码发送的消息

标题

 2020-04-21 11:07:59.913 DEBUG 48093 --- [DefaultMessageListenerContainer-2] 
 c.b.i.c.listeners.AbstractAgiListener    : Receive message on MQ with header : {someargs}

信息

 RFH ¨ÿÿÿþ        ¸ <mcd><Msd>jms_bytes</Msd></mcd> 8<jms><Dst>queue:///myqueue</Dst>
<Pri>0</Pri></jms>    <usr><Sender>mysender</Sender></usr><Document ...>...</Document>

知道如何解决吗？谢谢你。

更新 1

即使使用以下代码，消息之前仍然存在信息

def message = new MQMessage()
def rfh2 = new MQRFH2()
rfh2.setEncoding(CMQC.MQENC_NATIVE)
rfh2.setCodedCharSetId(CMQC.MQCCSI_INHERIT)
rfh2.setFormat(CMQC.MQFMT_NONE)
rfh2.setNameValueCCSID(1208)
rfh2.setFieldValue('mcd', 'Msd', 'jms_byte')
rfh2.setFieldValue('usr', 'Sender', 'mysender')
rfh2.write(message)
4

1 回答 1

2

rfh2.setFormat("RHF2")

那是无效的。

rfh2.setFormat(CMQC.MQFMT_NONE)

这表示消息有效负载没有类型。即它不是字符串或者在这个RFH2结构之后没有找到另一个内部。

像 MQ Visual Edit 一样吗？

是的，MQ Visual Edit 使用 MQRFH2 类，但您需要了解，编写正确的 MQMD.Format 值取决于程序员。

您是否将消息的 MQMD.Format 设置为 MQFMT_RF_HEADER_2：

msg.format = CMQC.MQFMT_RF_HEADER_2;

我已经在 StackOverflow 和我的博客上发布了许多功能齐全的 Java（非 JMS）程序，它们创建了 MQRFH2（又名 JMS）消息。

您可以用我的名字搜索 MQRFH2 以在此处找到它们。

这里描述了 MQ Visual Edit 如何处理显示命名属性与原始 MQRFH2 消息。https://www.capitalware.com/rl_blog/?p=4786

这里展示了如何在非 JMS Java 应用程序中创建 JMS (MQRFH2) 消息： https ://www.capitalware.com/rl_blog/?p=4823

最后，显示在非 JMS Java 应用程序中处理传入的 JMS (MQRFH2) 消息：https ://www.capitalware.com/rl_blog/?p=4811

于 2020-04-21T16:41:45.333 回答