Browse files

basic.recover

  • Loading branch information...
1 parent e99bb17 commit 6eb1b7ac5966d6b8e928109649c60a8a623c02c2 @paolo-losi committed Jan 17, 2011
Showing with 3 additions and 1 deletion.
  1. +0 −1 TODO
  2. +3 −0 stormed/channel.py
View
1 TODO
@@ -1,5 +1,4 @@
* review of all methods
- - basic.recover?
- tx.select, tx.commit, tx.rollback
* check conn/channel status before sending frames
* logging
View
3 stormed/channel.py
@@ -123,6 +123,9 @@ def set_consumer(consumer_tag):
arguments = dict())
self.send_method(_consume, set_consumer)
+ def recover(self, requeue=False, callback=None):
+ self.send_method(basic.Recover(requeue=requeue), callback)
+
def flow(self, active, callback=None):
self.send_method(Flow(active=active), callback)

0 comments on commit 6eb1b7a

Please sign in to comment.