| 2012-03-30 13:49:18 |
Jurdanas Kriauciunas |
description |
Hi,
AMQClient.channels dict stores all opened channels. But if error ocures but channel has internal variable to check if it was closed.
But if error occurs channel is closed, AMQChannel.closed variable updated but AMQPClient.channels dict is not updated.
I have done a small patch: AMQClient.channel() function checks not only if channel exists but also checks 'closed' variable. And recreates channel if needed. |
Hi,
AMQClient.channels dict stores all opened channels. But if error occurs channel is closed, AMQChannel.closed variable updated but AMQPClient.channels dict is not updated.
I have done a small patch: AMQClient.channel() function checks not only if channel exists but also checks 'closed' variable. And recreates channel if needed. |
|
