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

why should it not be me

parent 9bef9a1f
No related branches found
No related tags found
No related merge requests found
...@@ -159,7 +159,7 @@ class Consumer(Channeler): ...@@ -159,7 +159,7 @@ class Consumer(Channeler):
if isinstance(payload, BasicCancel): if isinstance(payload, BasicCancel):
# Consumer Cancel Notification - by RabbitMQ # Consumer Cancel Notification - by RabbitMQ
self.methods([BasicCancelOk(payload.consumer_tag.tobytes()), ChannelClose(0, b'Received basic.cancel', 0, 0)]) self.methods([BasicCancelOk(payload.consumer_tag), ChannelClose(0, b'Received basic.cancel', 0, 0)])
return return
if isinstance(payload, BasicCancelOk): if isinstance(payload, BasicCancelOk):
......
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