Hmm, I switched to use pika as transport, and now the consumer
connection is not recognizing the broke connection...
I'm using connection.drain_events(), which actually returns with an
error when RabbitMQ is restarted if I use py-amqplib.
Is there a parameter or similar I have to set when creating the
connection for it to recognize the restart?
Thanks / J