0

我目前正在通过 python Stomp.py 库将消息从自定义系统推送到 ActiveMQ 实例。当我在发送命令中提供带有自定义标题的字典作为“标题”参数时，这将失败。

destination = self.subscription_id.queue_name
# Connect to the server
conn.connect(username=$username,
             password=$password,
             headers={})
# Send the actual message out
conn.send(destination, self.body, headers=self.header)
conn.disconnect()

由于某种原因，标头未能向我提供此错误：

ValueError: dictionary update sequence element #0 has length 1; 2 is required

堆栈跟踪的最后一部分：

File "/custom_addons/activemq_message.py", line 124, in send_to_queue
conn.send(destination, self.body, headers=self.header)

File "/usr/local/lib/python2.7/dist-packages/stomp/protocol.py", line 151, in send
headers = utils.merge_headers([headers, keyword_headers])

File "/usr/local/lib/python2.7/dist-packages/stomp/utils.py", line 166, in merge_headers
headers.update(header_map)

这与我在哪里实际提供字典中的任何内容或只是发送一个空字典无关。

它也独立于我在连接级别或发送（或两者）提供标头。

它似乎在某个时候将标头转换为字符串，但我无法弄清楚这是否是故意的。我也不知道如何解决这个问题。

任何线索将不胜感激。

4

1 回答 1

0

找到了原因，在代码的其他部分中，标头存储在字符串字段中。它随后尝试发送一个 unicode 来代替字典。

由于我无法编辑源代码，因此我使用“ast”模块的方法“literal_eval”将 unicode 转换为字典并且它可以工作。

于 2017-02-13T15:14:05.997 回答