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.
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.