Dmitriy
3 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
1 deletions
-
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 with self.listener_queue.iterator() as queue_iter: |
|
|
async for message in queue_iter: |
|
|
async for message in queue_iter: |
|
|
with message.process(): |
|
|
async with message.process(): |
|
|
yield pickle.loads(message.body) |
|
|
yield pickle.loads(message.body) |
|
|
except Exception: |
|
|
except Exception: |
|
|
self._get_logger().error('Cannot receive from rabbitmq... ' |
|
|
self._get_logger().error('Cannot receive from rabbitmq... ' |
|
|
|
