From 1d0b8756f13f3d07ab4ebddd870ebf0779a095b7 Mon Sep 17 00:00:00 2001 From: Dmitriy Date: Sun, 27 Mar 2022 17:04:12 +1000 Subject: [PATCH] fixed #897: compatibility with aio-pika=7 --- src/socketio/asyncio_aiopika_manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/socketio/asyncio_aiopika_manager.py b/src/socketio/asyncio_aiopika_manager.py index 96dcec6..eff3f8c 100644 --- a/src/socketio/asyncio_aiopika_manager.py +++ b/src/socketio/asyncio_aiopika_manager.py @@ -93,7 +93,7 @@ class AsyncAioPikaManager(AsyncPubSubManager): # pragma: no cover async with self.listener_queue.iterator() as queue_iter: async for message in queue_iter: - with message.process(): + async with message.process(): yield pickle.loads(message.body) except Exception: self._get_logger().error('Cannot receive from rabbitmq... '