Bugfix (reference to non-existing 'cfg' variable)

main.py

@@ -100,7 +100,7 @@ def send_record_to_the_metadata_processor( the_cfg, the_record ):
     del the_cfg['rabbitmq']['routing_key_1']
 
     channel.exchange_declare(exchange=exchange, exchange_type='direct')
-    channel.queue_declare(queue=queue_name, durable=True, arguments={'x-message-ttl' : cfg['rabbitmq']['ttl']})
+    channel.queue_declare(queue=queue_name, durable=True, arguments={'x-message-ttl' : the_cfg['rabbitmq']['ttl']})
     channel.queue_bind(exchange=exchange, queue=queue_name, routing_key=routing_key)
 
     msg = dict()