(self, awaitable)
| 61 | self.log.error("Global callback error: {}".format(e), exc_info=True) |
| 62 | |
| 63 | async def handle_exceptions(self, awaitable): |
| 64 | try: |
| 65 | return await awaitable |
| 66 | except websockets.exceptions.ConnectionClosedOK: |
| 67 | pass # No handler was registered for this event |
| 68 | except Exception as e: |
| 69 | self.log.error("WebSocket error: {}".format(e), exc_info=True) |
| 70 | |
| 71 | async def fire_event(self, exchange=None, queue=None, timestamp=True, **callback_kwargs): |
| 72 | exchange = exchange or self.default_exchange |