fixed miguelgrinberg#897: compatibility with aio-pika=7

dimastbk · Mar 27, 2022 · 1d0b875 · 1d0b875
1 parent 4d5e36d
commit 1d0b875
Showing 1 changed file with 1 addition and 1 deletion.
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... '