github
/
jumpserver
mirror of https://github.com/jumpserver/jumpserver
1
0
Fork 0
Code Issues Releases Wiki Activity

fix: Error subpub_msg log

pull/14379/head
feng 2024-10-17 15:14:23 +08:00 committed by Bryan
parent 6720ecc6e0
commit 4b981fd93c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/common/utils/connection.py
View File

@ -47,7 +47,7 @@ class Subscription:
self.ch = pb.ch self.ch = pb.ch
self.sub = sub self.sub = sub
self.unsubscribed = False self.unsubscribed = False
logger.info("Subscribed to channel: ", sub) logger.info(f"Subscribed to channel: {sub}")
def _handle_msg(self, _next, error, complete): def _handle_msg(self, _next, error, complete):
""" """
@ -106,11 +106,11 @@ class Subscription:
def unsubscribe(self): def unsubscribe(self):
self.unsubscribed = True self.unsubscribed = True
logger.info("Unsubscribed from channel: ", self.sub) logger.info(f"Unsubscribed from channel: {self.sub}")
try: try:
self.sub.close() self.sub.close()
except Exception as e: except Exception as e:
logger.warning('Unsubscribe msg error: {}'.format(e)) logger.warning(f'Unsubscribe msg error: {e}')
def retry(self, _next, error, complete): def retry(self, _next, error, complete):
logger.info('Retry subscribe channel: {}'.format(self.ch)) logger.info('Retry subscribe channel: {}'.format(self.ch))