Commit 062cdb67c1d73263ba0231d5e1416b41d10e5e10
1 parent
8cae4b85
Exists in
release
Add heartbeat_interval on connections instance
Showing
1 changed file
with
2 additions
and
2 deletions
Show diff stats
core/PikaManager.py
| @@ -37,8 +37,8 @@ class PikaManager: | @@ -37,8 +37,8 @@ class PikaManager: | ||
| 37 | self.credentials = pika.PlainCredentials(username, password) | 37 | self.credentials = pika.PlainCredentials(username, password) |
| 38 | 38 | ||
| 39 | def add_blockConnection(self): | 39 | def add_blockConnection(self): |
| 40 | - self.conn_send = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials)) | ||
| 41 | - self.conn_receive = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials)) | 40 | + self.conn_send = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials, heartbeat_interval = 0)) |
| 41 | + self.conn_receive = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, credentials = self.credentials, heartbeat_interval = 0)) | ||
| 42 | 42 | ||
| 43 | def _reload_connection(self, connection): | 43 | def _reload_connection(self, connection): |
| 44 | try: | 44 | try: |