Skip to content

error during reconnect

error in receive message loop Connection is already closed. - trying to reconnect
reconnect, attempt 1
ERROR:asyncio:Exception in callback PulsarMessageHandler.receive_request()
handle: <Handle PulsarMessageHandler.receive_request()>
Traceback (most recent call last):
  File "/usr/lib64/python3.8/asyncio/events.py", line 81, in _run
    self._context.run(self._callback, *self._args)
  File "/home/eggi/workspace/python/de-smart-monitoring-backend-module/env/src/demessaging/demessaging/PulsarMessageHandler.py", line 215, in receive_request
    self.reconnect()
  File "/home/eggi/workspace/python/de-smart-monitoring-backend-module/env/src/demessaging/demessaging/PulsarMessageHandler.py", line 147, in reconnect
    self.loop.remove_reader(self.subscription)
  File "/usr/lib64/python3.8/asyncio/selector_events.py", line 336, in remove_reader
    self._ensure_fd_no_transport(fd)
  File "/usr/lib64/python3.8/asyncio/selector_events.py", line 244, in _ensure_fd_no_transport
    raise ValueError(f"Invalid file object: {fd!r}") from None
ValueError: Invalid file object: <websocket._core.WebSocket object at 0x7f1fe5e11dc0>
error in pulsar ping routine: socket is already closed.