reconnect on on_close
This commit is contained in:
parent
4c6fed4b10
commit
ea9fc18c15
1 changed files with 4 additions and 4 deletions
|
|
@ -129,6 +129,10 @@ class Relay:
|
||||||
|
|
||||||
def _on_close(self, class_obj, status_code, message):
|
def _on_close(self, class_obj, status_code, message):
|
||||||
self.connected = False
|
self.connected = False
|
||||||
|
if self.error_threshold and self.error_counter > self.error_threshold:
|
||||||
|
pass
|
||||||
|
else:
|
||||||
|
self.check_reconnect()
|
||||||
pass
|
pass
|
||||||
|
|
||||||
def _on_message(self, class_obj, message: str):
|
def _on_message(self, class_obj, message: str):
|
||||||
|
|
@ -139,10 +143,6 @@ class Relay:
|
||||||
def _on_error(self, class_obj, error):
|
def _on_error(self, class_obj, error):
|
||||||
self.connected = False
|
self.connected = False
|
||||||
self.error_counter += 1
|
self.error_counter += 1
|
||||||
if self.error_threshold and self.error_counter > self.error_threshold:
|
|
||||||
pass
|
|
||||||
else:
|
|
||||||
self.check_reconnect()
|
|
||||||
|
|
||||||
def _on_ping(self, class_obj, message):
|
def _on_ping(self, class_obj, message):
|
||||||
return
|
return
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue