Skip to content
Snippets Groups Projects
Commit 7519e980 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

fixes #34

parent afcaad64
No related branches found
No related tags found
No related merge requests found
...@@ -187,7 +187,9 @@ class Consumer(Channeler): ...@@ -187,7 +187,9 @@ class Consumer(Channeler):
# you'll blow up big next time you try to use this consumer if you # you'll blow up big next time you try to use this consumer if you
# can't cancel, but just close # can't cancel, but just close
if self.consumer_tag is not None: if self.consumer_tag is not None:
self.method(BasicCancel(self.consumer_tag, False)) self.method_and_watch(BasicCancel(self.consumer_tag, False),
[BasicCancelOk],
self.on_close)
else: else:
self.method(ChannelClose(0, b'cancelling', 0, 0)) self.method(ChannelClose(0, b'cancelling', 0, 0))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment