diff --git a/integration_worker.py b/integration_worker.py index f2602d2a84ecb7feb52bc3e60a946a8525b8c676..7e04749eab781b5bd2054e0b53b9a7747bb22569 100755 --- a/integration_worker.py +++ b/integration_worker.py @@ -34,7 +34,7 @@ AMQP_PORT = os.environ.get("AMQP_PORT", 5672) AMQP_VHOST = os.environ.get("RUNMODE", "dev") AMQP_USER = os.environ.get("AMQP_USER", "integrator") AMQP_PASSWORD = os.environ.get("AMQP_PASSWORD") -AMQP_HEARTBEAT = os.environ.get("AMQP_HEARTBEAT", 600) +AMQP_HEARTBEAT = os.environ.get("AMQP_HEARTBEAT", 0) AMQP_TIMEOUT = os.environ.get("AMQP_TIMEOUT", 300) ZABBIX_HOST = platform.node() @@ -330,7 +330,7 @@ def main(args): AMQP_VHOST, credentials, heartbeat=AMQP_HEARTBEAT, - blocked_connection_timeout=AMQP_TIMEOUT, + # blocked_connection_timeout=AMQP_TIMEOUT, ) connection = pika.BlockingConnection(parameters) logging.debug("Listening on %s:%s", AMQP_SERVER, routing_key)