Update asr

new_experiment/queue_base.py

@@ -8,7 +8,8 @@ from pika.adapters.blocking_connection import BlockingChannel
 from new_experiment.utils.param_util import get_param
 
 _RABBIT_URL = get_param('RABBIT_URL',
-                        'amqps://rabbit_user:kz6m4972OUHFmtUcPOHx4kF3Lj6yw7lo@rabbit-asr-benchmarks.theliver.pl:5671/')
+                        'amqps://rabbit_user:kz6m4972OUHFmtUcPOHx4kF3Lj6yw7lo'
+                        '@rabbit-asr-benchmarks.theliver.pl:5671/?heartbeat=0')
 
 
 def ack_message(channel, delivery_tag):
@@ -38,7 +39,6 @@ def process_queue(queue_name: str, process_message: Callable[[bytes], None], pre
         threads.append(t)
 
     parameters = pika.URLParameters(_RABBIT_URL)
-    parameters._heartbeat = 0
     connection = pika.BlockingConnection(parameters)
     channel = connection.channel()
     channel.basic_qos(prefetch_count=prefetch_count)