diff --git a/core/PikaManager.py b/core/PikaManager.py index dd4b556..17415ee 100644 --- a/core/PikaManager.py +++ b/core/PikaManager.py @@ -37,8 +37,8 @@ class PikaManager: self.credentials = pika.PlainCredentials(username, password) def add_blockConnection(self): - self.conn_send = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials)) - self.conn_receive = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials)) + self.conn_send = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials, heartbeat_interval = 0)) + self.conn_receive = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials, heartbeat_interval = 0)) def _reload_connection(self, connection): try: -- libgit2 0.21.2