diff --git a/workers/doc-enricher.py b/workers/doc-enricher.py index 92bc14854c60fda561f4fc511e69f972087c1769..af44a6ab0d7917306d95ad491541bf9f0f129aab 100644 --- a/workers/doc-enricher.py +++ b/workers/doc-enricher.py @@ -314,8 +314,13 @@ def enrich_docs( channel, method, properties, body ): def main(cfg): #from lib.close_connection import on_timeout + credentials = pika.PlainCredentials(username=cfg['rabbitmq']['user'], password=cfg['rabbitmq']['password']) - connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) + connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], + port=cfg['rabbitmq_port'], + credentials=credentials)) + + # connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) #timeout = 5 #connection.add_timeout(timeout, on_timeout(connection)) diff --git a/workers/doc-indexer.py b/workers/doc-indexer.py index 4e302a7c4f116bb3f6ccbc1faea821b6b4172c34..1143c99cdfbe6f8056cbe241e051b7cf2c2a9c28 100644 --- a/workers/doc-indexer.py +++ b/workers/doc-indexer.py @@ -225,8 +225,13 @@ def index_docs(channel, method, properties, body): def main(cfg): #from lib.close_connection import on_timeout + credentials = pika.PlainCredentials(username=cfg['rabbitmq']['user'], password=cfg['rabbitmq']['password']) - connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) + connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], + port=cfg['rabbitmq_port'], + credentials=credentials)) + + # connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) # timeout = 5 # connection.add_timeout(timeout, on_timeout(connection)) diff --git a/workers/doc-processor.py b/workers/doc-processor.py index ba1e9ddae5841f638d885e3c3322d1173fff1c10..43dedf7ea866c1a861a9f3f9c46305c9a4947210 100644 --- a/workers/doc-processor.py +++ b/workers/doc-processor.py @@ -184,8 +184,13 @@ def process_docs( channel, method, properties, body ): def main(cfg): #from lib.close_connection import on_timeout + credentials = pika.PlainCredentials(username=cfg['rabbitmq']['user'], password=cfg['rabbitmq']['password']) - connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'],port=cfg['rabbitmq_port'])) + connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], + port=cfg['rabbitmq_port'], + credentials=credentials)) + + # connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) #timeout = 5 #connection.add_timeout(timeout, on_timeout(connection)) diff --git a/workers/metadata-processor.py b/workers/metadata-processor.py index 4528b2355d05833a70e5a6a5a51e470199d62a54..c4c4fd06d5f92155bf1331b169d08bef3cf83783 100644 --- a/workers/metadata-processor.py +++ b/workers/metadata-processor.py @@ -518,7 +518,13 @@ def main(cfg): # logging.debug(cfg) #global connection - connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) + credentials = pika.PlainCredentials(username=cfg['rabbitmq']['user'], password=cfg['rabbitmq']['password']) + + connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], + port=cfg['rabbitmq_port'], + credentials=credentials)) + + # connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) # timeout = 5 # connection.add_timeout(timeout, on_timeout(connection)) channel = connection.channel() diff --git a/workers/reindexer.py b/workers/reindexer.py index 2bcfb66e3348984f41b4ff1f5b1afad2e48a280d..f20ad024aff9e75df7ffe831a56dbf42354bba92 100644 --- a/workers/reindexer.py +++ b/workers/reindexer.py @@ -239,8 +239,13 @@ def on_msg_callback(channel, method, properties, body): def main(cfg): #from lib.close_connection import on_timeout + credentials = pika.PlainCredentials(username=cfg['rabbitmq']['user'], password=cfg['rabbitmq']['password']) - connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) + connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], + port=cfg['rabbitmq_port'], + credentials=credentials)) + + # connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) #timeout = 5 #connection.add_timeout(timeout, on_timeout(connection)) channel = connection.channel() diff --git a/workers/sample-generator.py b/workers/sample-generator.py index b13fd14c40c8145f0366094425dbbdf477ca920b..c949dd856d0bf4617eb41c2d65ea69f39b0bfab3 100644 --- a/workers/sample-generator.py +++ b/workers/sample-generator.py @@ -281,8 +281,13 @@ def main(cfg): # es_logger.setLevel(logging.INFO) #from lib.close_connection import on_timeout + credentials = pika.PlainCredentials(username=cfg['rabbitmq']['user'], password=cfg['rabbitmq']['password']) - connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) + connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], + port=cfg['rabbitmq_port'], + credentials=credentials)) + + # connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg['rabbitmq_host'], port=cfg['rabbitmq_port'])) #timeout = 5 #connection.add_timeout(timeout, on_timeout(connection))