BUG FIX: change heartbeat from 0 to 600

rainbowers · Dec 26, 2019 · a45b759 · a45b759
1 parent ebf6939
commit a45b759
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/settings/config.py b/settings/config.py
@@ -128,7 +128,7 @@ def ST_maximum_lifetime(self) -> int:
     # 高危服务前缀，用于判断离线票据破解的相关危险程度, 以下是默认的列表，可根据需要添加
     @property
     def high_risk_spn_prefix(self) -> list:
-        return self.kerberos()["high_risk_spn_prefix_setting"]
+        return self.kerberos()["high_risk_spn_prefix"]
 
     # 高危kerberos限定委派服务前缀，以下是默认的列表，可根据需要添加
     @property

diff --git a/tools/database/Consumer.py b/tools/database/Consumer.py
@@ -32,7 +32,7 @@ def check_connection(self) -> bool:
                 host=MqConfig.host,
                 port=MqConfig.port,
                 credentials=self.auth,
-                heartbeat=0
+                heartbeat=600
             ))
             return True
         except Exception as e:
@@ -49,10 +49,10 @@ def connect(self):
             heartbeat=0
         ))
         self.channel = self.connection.channel()
+        self.channel.basic_qos(prefetch_count=1)
         self.channel.exchange_declare(exchange=MqConfig.exchange, exchange_type=MqConfig.exchange_type, durable=True)
         self.channel.queue_declare(queue=MqConfig.main_queue, durable=True)
         self.channel.queue_bind(exchange=MqConfig.exchange, queue=MqConfig.main_queue)
-        self.channel.basic_qos(prefetch_count=1)
         self.channel.basic_consume(queue=MqConfig.main_queue, on_message_callback=self.callback, auto_ack=True)
 
     def run(self, handle_func):