|
success = asyncio.ensure_future( |
|
self.handle_async_message(event), loop=loop) |
|
else: |
|
success = self.handle_message(event) |
|
|
|
if success: |
|
self.accept(event.delivery) |
|
else: |
|
self.reject(event.delivery) |
AFAICT, this always returns a Future and will always test as successful.