txAMQP.protocol.AMQPClient doesn't seem to support redirects or setting insist=True to avoid redirects.

[Allan Bailey]

txAMQP.protocol.AMQPClient doesn't seem to support redirects or setting insist=True to avoid redirects.

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.

[Allan Bailey (zirpu)]

here's a patch for 0.3 to add the insist option to the connection.

====
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.connection_open(self.vhost)
---
> yield channel0.connection_open(self.vhost, insist=self.insist)
====

NOTE: I set insist=True for our internal application, but it should probably default to False.

[Allan Bailey (zirpu)]

Update: This works for me in production.

[Dan Di Spaltro (dan-dispaltro)]

I would actually like to see us implement the redirect, but that is more difficult.

[Esteve Fernandez (esteve)]

Fixed in rev 49. Thanks Allan!