txamqp-user team mailing list archive
-
txamqp-user team
-
Mailing list archive
-
Message #00074
rabbitmq: channel.basic_consume crashes channel
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)
Follow ups