From b4b55e1fb5e9d837b3301b5b873d9a7fe2a12023 Mon Sep 17 00:00:00 2001 From: Dmitriy Date: Mon, 28 Mar 2022 08:08:30 +1000 Subject: [PATCH] fixed #897: compatibility with aio-pika>=7 (#900) --- 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... '