Error during reconnect if pulsar service goes down
Exception raised when reconnect fails due to puslar service being unavailable
ping 2020-04-24 08:27:34.851430
error in receive message loop Connection is already closed. - trying to reconnect
reconnect, attempt 1
Exception in callback None()
handle: <Handle cancelled>
Traceback (most recent call last):
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/src/demessaging/demessaging/PulsarMessageHandler.py", line 159, in receive_request
msg = self.subscription.recv()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 314, in recv
opcode, data = self.recv_data()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 331, in recv_data
opcode, frame = self.recv_data_frame(control_frame)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 344, in recv_data_frame
frame = self.recv_frame()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 378, in recv_frame
return self.frame_buffer.recv_frame()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_abnf.py", line 361, in recv_frame
self.recv_header()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_abnf.py", line 309, in recv_header
header = self.recv_strict(2)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_abnf.py", line 396, in recv_strict
bytes_ = self.recv(min(16384, shortage))
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 453, in _recv
return recv(self.sock, bufsize)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_socket.py", line 115, in recv
"Connection is already closed.")
websocket._exceptions.WebSocketConnectionClosedException: Connection is already closed.
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/lib/python3.6/asyncio/events.py", line 127, in _run
self._callback(*self._args)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/src/demessaging/demessaging/PulsarMessageHandler.py", line 206, in receive_request
self.reconnect()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/src/demessaging/demessaging/PulsarMessageHandler.py", line 145, in reconnect
self.connect()
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/src/demessaging/demessaging/PulsarMessageHandler.py", line 76, in connect
self.subscription = self.open_socket(subscription=subscription_name)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/src/demessaging/demessaging/PulsarMessageHandler.py", line 268, in open_socket
sock = websocket.create_connection(topic_url)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 515, in create_connection
websock.connect(url, **options)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_core.py", line 223, in connect
options.pop('socket', None))
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_http.py", line 121, in connect
sock = _open_socket(addrinfo_list, options.sockopt, options.timeout)
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_http.py", line 201, in _open_socket
raise err
File "/home/gfz-gi/eggert/workspace/de-smart-monitoring-backend-module/venv/lib/python3.6/site-packages/websocket/_http.py", line 176, in _open_socket
sock.connect(address)
ConnectionRefusedError: [Errno 111] Connection refused