struct Type Error when consume internal log message.

[barryz]

my demo code:

from kombu import Exchange, Queue
from kombu.mixins import ConsumerMixin
from kombu import Connection


task_exchange = Exchange(name="amq.rabbitmq.log", type="topic")
task_queues = [Queue(exchange=task_exchange, routing_key='error.#', exclusive=True, auto_delete=True)]


class Worker(ConsumerMixin):

    def __init__(self, connection):
        self.connection = connection

    def get_consumers(self, Consumer, channel):
        return [Consumer(queues=task_queues,
                         # accept=['pickle', 'json'],
                         callbacks=[self.process_task])]

    def process_task(self, body, message):
        print(body)
        message.ack()

if __name__ == '__main__':
    with Connection('amqp://admin:admin@local.elenet.me:5672//') as conn:
        try:
            worker = Worker(conn)
            worker.run()
        except KeyboardInterrupt:
            print('bye bye')

then catch an exception:

File "/usr/lib/python2.7/site-packages/amqp-2.0.2-py2.7.egg/amqp/connection.py", line 440, in blocking_read
    frame = self.transport.read_frame()
  File "/usr/lib/python2.7/site-packages/amqp-2.0.2-py2.7.egg/amqp/transport.py", line 235, in read_frame
    frame_type, channel, size = unpack('>BHI', frame_header)
TypeError: Struct() argument 1 must be string, not unicode

After I change this code, it works well.

# frame_type, channel, size = unpack('>BHI', frame_header)
frame_type, channel, size = unpack(str('>BHI'), frame_header)

[ask]

What Python version is this?

[barryz]

python 2.7.5