我试图从python的amqp代理接收消息。这里是我的代码:python qpid消息编码
#!/usr/bin/python
import sys
import os
import getopt
from qpid.messaging import *
from qpid.log import enable, DEBUG
broker_rcv = "admin/[email protected]:IP"
address_rcv = "broadcast.QUEUE_NAME.QUEUE_NAME" + "; { node: { type: queue }, assert: never , create: never, mode: " + "browse" + " }"
connection_rcv = Connection(broker_rcv)
connection_rcv.open()
session_rcv = connection_rcv.session()
receiver = session_rcv.receiver(address_rcv)
msg = receiver.fetch(timeout=None)
print msg.content
但是当我尝试打印消息时,我看到他们在奇怪的编码,并且没有办法如何更改消息编码。
我在做什么错了?
后一些奇怪的编码字符串。 – Blender 2012-02-14 15:19:24
AEDEXCHAED “AEDN0:UAE迪拉姆@HR EURAED XLAħ ANGEXCHANG” ANGN0:荷兰@HR EURANG XLAħ AUDEXCHAUD “AUDN0:AUSTRAL DOLLAR @ HR EURAUD XLAħ AZNEXCHAZN” AZNN0:阿塞拜疆@HR – user1209304 2012-02-14 15:25:16
如果我删除了打印并留下了msg.content,我收到如下消息:\ n2 \ xa2 \ x06/\ n \ x0520001 \ x12 \ nEUREX 14.0 \ x1a \ x05EUREX \ x01 * \ x07 \ x08 \ xcd \ x0f \ x10 \ x0b \ x18 \ x0c0 \ x00:\ x06 \ x08 \ x0e \ x10 \ x13 \ x18 \ x0e \ x12L \ x8a \ xe2 \ tH \ n \ x03AED \ x12 \ x04EXCH \ x1a \ x03AED“\ – user1209304 2012-02-14 15:28:11