Comment 1 for bug 531521

Revision history for this message
Allan Bailey (zirpu) wrote :

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.