From 6d80301081aac1509650ca2a778ae23d8a9f1047 Mon Sep 17 00:00:00 2001 From: Wesnydy Ribeiro Date: Thu, 26 Jan 2017 15:27:13 -0300 Subject: [PATCH] Connection without credentials configuration --- core/PikaManager.py | 29 ++++++++++++++--------------- core/logger.py | 2 +- core/translator.py | 2 +- 3 files changed, 16 insertions(+), 17 deletions(-) diff --git a/core/PikaManager.py b/core/PikaManager.py index 0cd442a..bdaa51f 100644 --- a/core/PikaManager.py +++ b/core/PikaManager.py @@ -18,19 +18,7 @@ import json class PikaManager: - def __init__(self, ip): - """ - Initialize the class without credentials. - - Parameters - ---------- - ip : string - The server IP. - """ - self.server_ip = ip - self.MAX_ERR_ATTEMPT = 3 - - def __init__(self, ip, username, password): + def __init__(self, ip, username=None, password=None): """ Initialize the class with credentials. @@ -45,8 +33,12 @@ class PikaManager: """ self.server_ip = ip self.MAX_ERR_ATTEMPT = 3 - self.add_credentials(username, password) - self.add_blockConnection() + + if not all((username, password)): + self.add_localBlockConnection() + else: + self.add_credentials(username, password) + self.add_blockConnection() def add_credentials(self, username, password): """ @@ -61,6 +53,13 @@ class PikaManager: """ self.credentials = pika.PlainCredentials(username, password) + def add_localBlockConnection(self): + """ + Create the blocking connection object. + """ + self.conn_send = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, heartbeat_interval = 0)) + self.conn_receive = pika.BlockingConnection(pika.ConnectionParameters(host = self.server_ip, heartbeat_interval = 0)) + def add_blockConnection(self): """ Create the blocking connection object. Credentials are used. diff --git a/core/logger.py b/core/logger.py index b178a26..61a81e7 100644 --- a/core/logger.py +++ b/core/logger.py @@ -23,7 +23,7 @@ from time import sleep SERVER_URL = sys.argv[1] # Manager of queues connections. -manager = PikaManager.PikaManager("150.165.205.10", "test", "test") +manager = PikaManager.PikaManager("localhost") # Logging configuration. logger = logging.getLogger('text_container') diff --git a/core/translator.py b/core/translator.py index 54193c2..748b89d 100755 --- a/core/translator.py +++ b/core/translator.py @@ -20,7 +20,7 @@ from PortGlosa import traduzir from time import sleep # Manager of queues connections. -manager = PikaManager.PikaManager("localhost", "test", "test") +manager = PikaManager.PikaManager("localhost") def run(ch, method, properties, body): """ -- libgit2 0.21.2