txAMQP.protocol.AMQPClient doesn't seem to support redirects or setting insist=True to avoid redirects.
Bug #531521 reported by
Allan Bailey
This bug affects 2 people
Affects | Status | Importance | Assigned to | Milestone | |
---|---|---|---|---|---|
txAMQP |
Fix Released
|
Undecided
|
Allan Bailey |
Bug Description
txAMQP.
I have an HA pair and have had cases where the client was hung not able to connect to the specified server
because it was (apparently) getting a redirect to the other server.
I cannot find anything in the code, version 0.3, where it seems to be handling the case of receiving a REDIRECT
and trying to connect to the other server.
Changed in txamqp: | |
status: | Fix Committed → Fix Released |
To post a comment you must log in.
here's a patch for 0.3 to add the insist option to the connection.
==== connection_ open(self. vhost) connection_ open(self. vhost, insist=self.insist)
55c55
< def invoke(self, method, args, content = None):
---
> def invoke(self, method, args, content=None):
208c208
< def __init__(self, delegate, vhost, spec, heartbeat=0):
---
> def __init__(self, delegate, vhost, spec, heartbeat=0, insist=True):
216c216
<
---
> self.insist = insist
356c356
< yield channel0.
---
> yield channel0.
====
NOTE: I set insist=True for our internal application, but it should probably default to False.