From 60680b4e78e35bbd6a2c6510eb2508b61f9eeb61 Mon Sep 17 00:00:00 2001 From: Matthias Urlichs Date: Thu, 5 Jan 2023 09:59:32 +0100 Subject: [PATCH] Lock me --- async_amqp/channel.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/async_amqp/channel.py b/async_amqp/channel.py index 3f16156..9688855 100644 --- a/async_amqp/channel.py +++ b/async_amqp/channel.py @@ -493,7 +493,8 @@ async def queue_unbind(self, queue_name, exchange_name, routing_key, arguments=N routing_key=routing_key, arguments=arguments ) - return await self._write_frame_awaiting_response('queue_unbind', self.channel_id, request, no_wait=False) + async with self._queue_bind_lock: + return await self._write_frame_awaiting_response('queue_unbind', self.channel_id, request, no_wait=False) async def queue_unbind_ok(self, frame): future = self._get_waiter('queue_unbind')