Lock me

python-trio · Jan 5, 2023 · 60680b4 · 60680b4
1 parent c866969
commit 60680b4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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')