txamqp-user team mailing list archive

[bartek <bartek@xxxxxxxxxxxx>]

I'm trying to get a consumer to work; I run the following code:

exid = 'broadcast'
yield self.exchange_declare(0, exchange=exid, type='fanout')
qid = 'broadcast_listen'
yield self.queue_declare(queue=qid)
yield self.channel.queue_bind(queue=qid, exchange=exid)
subscription = yield self.channel.basic_consume(queue=qid)
queue = yield self.client.queue(consumer_tag=subscription.consumer_tag)

which is copied nearly intact from test suites. This line:

subscription = yield self.channel.basic_consume(queue=qid)

blocks, the channel disappears from rabbitmq, and rabbit's sasl log
shows a crash report, the most important line being:

    exception exit: {amqp_error,frame_error,
                                "cannot decode
    <<0,0,16,98,114,111,97,100,99,97,115,116,95,108,105,115,116,101,110,0,0,0,0,0,0>>",
    'basic.consume'}

No exceptions in python code.

All other operations (basic_publish, basic_get) are ok.

Am I doing something wrong, or did I hit a bug? I run rabbit 2.2.0,
erlang R14B, python 2.7, txamqp 0.3

Thanks

-- 
A distributed system is one in which the failure of a computer you
didn't even know existed can render your own computer unusable. (Leslie
Lamport)


-- 
I don't want to belong to any club that accepts people like me as
members. (Groucho Marx)