4

我正在尝试使用pymqi将字符串消息放入MQ，代码如下；

import xml.dom.minidom as minidom
import pymqi

class PutMQ:
    def put_mq(args1):
        doc = minidom.parse(args1)                       
        queue_manager = "NameQueueManager"
        channel = "ChannelName"
        host = "HostName"
        port = "PortNumber"
        conn_info = "%s(%s)" % (host, port)

        qmgr = pymqi.QueueManager(None)

        qmgr.connectTCPClient(queue_manager, pymqi.cd(), channel, conn_info)

        putq = pymqi.Queue(qmgr, 'QueueName')


        putq.put(doc.toprettyxml())

        putq.close()
        qmgr.disconnect()
    put_mq('C://MQ//myMessage.xml')

当我运行此代码时，它不会引发任何错误。因此，我感觉消息已成功放入所需的队列中。

但是，在将上述消息发送到队列后，我希望在我的一个应用程序屏幕中看到一条记录，但这并没有发生。

如果我通过 AppWatch（Web 界面）发送相同的消息，它会起作用，并且我也会在应用程序 UI 上看到预期的记录。

在 AppWatch（Web 界面）上，当我执行“Put Message”时，我提到消息类型为：“String Format (MQFMT_STRING)”。

如何在我的代码中指定消息格式为“MQFMT_STRING”？

感谢您对此的帮助。

4

1 回答 1

6

根据PyMQI Docs，这是 put 调用的定义：

put(msg[, mDesc, putOpts])

将字符串缓冲区“msg”放入队列中。如果队列尚未打开，则现在使用选项“MQOO_OUTPUT”打开它。

mDesc 是消息的 pymqi.md() MQMD 消息描述符。如果未通过，或者为 None，则使用默认的 md() 对象。

putOpts 是 put 调用的 pymqi.pmo() MQPMO 放置消息选项结构。如果未通过，或者为 None，则使用默认的 pmo() 对象。

如果提供了 mDesc 和/或 putOpts 参数，它们可能会被 put 操作更新。

因此，为了设置格式，您需要提供 MQMD 消息描述符，mDesc即 put 调用上的参数。

我自己没有尝试过，但是您的代码应该类似于：

md = pymqi.MD()
md.Format = CMQC.MQFMT_STRING
putq.put(doc.toprettyxml(), md, None)
于 2016-06-23T23:08:08.593 回答