diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py index f64b5516e6702a7cc0a1754f32798b3d0982d294..d269516a1b75950db24e88e3603cc56bdd5c9ee7 100644 --- a/coolamqp/attaches/consumer.py +++ b/coolamqp/attaches/consumer.py @@ -159,7 +159,7 @@ class Consumer(Channeler): if isinstance(payload, BasicCancel): # 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 if isinstance(payload, BasicCancelOk):