fixed miguelgrinberg#897: compatibility with aio-pika>=7 (miguelgrinberg#900)

dimastbk · web-flow · commit b4b55e1fb5e9 · 2022-03-27T23:08:30.000+01:00
diff --git a/src/socketio/asyncio_aiopika_manager.py b/src/socketio/asyncio_aiopika_manager.py
@@ -93,7 +93,7 @@ async def _listen(self):
 
                 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... '
