[rabbitmq-discuss] Pika 0.9.5 KeyError: Tx.SelectOk
mpietrek at skytap.com
Wed Mar 14 20:40:10 GMT 2012
I'm experiencing a KeyError exception, where the key is "Tx.SelectOk" when
using Pika 0.9.5.
The scenario: A simple program that simply writes two messages a second to a
queue. While this test is running, I stop the broker, then restart it a few
seconds later. I explicitly check for AMQPConnectionError exceptions, and if
seen reconnect to the broker. About half the time, the test works as
intended. However, other times I see the KeyError exception, which my guess
is not what's intended.
My writing code looks like this:
channel = self._channel
except AMQPConnectionError as e:
Digging into the traceback data, the faulting line is in Pika's
# Find our reply in our list of replies
for reply in self._replies:
if reply in replies:
frame = self._frames[reply] # THIS HERE IS THE LINE
self._received_response = True
Known issue? Expected and acceptable? Thoughts?
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the rabbitmq-discuss