From ec29378b6d2fe82aba645d867d9fdcabd08f5147 Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Thu, 25 May 2023 17:22:04 +0000
Subject: [PATCH] Common - Message Broker - NATS:
- Corrected URL format
---
src/common/message_broker/backend/nats/NatsBackend.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/common/message_broker/backend/nats/NatsBackend.py b/src/common/message_broker/backend/nats/NatsBackend.py
index 35de3acb3..bcbf2a721 100644
--- a/src/common/message_broker/backend/nats/NatsBackend.py
+++ b/src/common/message_broker/backend/nats/NatsBackend.py
@@ -19,8 +19,8 @@ from common.message_broker.Message import Message
from .._Backend import _Backend
from .NatsBackendThread import NatsBackendThread
-NATS_URI_TEMPLATE_AUTH = 'nats://{:s}:{:s}@nats.{:s}.svc.cluster.local:{:s}'
-NATS_URI_TEMPLATE_NOAUTH = 'nats://nats.{:s}.svc.cluster.local:{:s}'
+NATS_URI_TEMPLATE_AUTH = 'nats://{:s}:{:s}@{:s}.{:s}.svc.cluster.local:{:s}'
+NATS_URI_TEMPLATE_NOAUTH = 'nats://{:s}.{:s}.svc.cluster.local:{:s}'
class NatsBackend(_Backend):
def __init__(self, **settings) -> None: # pylint: disable=super-init-not-called
@@ -32,10 +32,10 @@ class NatsBackend(_Backend):
nats_password = get_setting('NATS_PASSWORD', settings=settings, default=None)
if nats_username is None or nats_password is None:
nats_uri = NATS_URI_TEMPLATE_NOAUTH.format(
- nats_namespace, nats_client_port)
+ nats_namespace, nats_namespace, nats_client_port)
else:
nats_uri = NATS_URI_TEMPLATE_AUTH.format(
- nats_username, nats_password, nats_namespace, nats_client_port)
+ nats_username, nats_password, nats_namespace, nats_namespace, nats_client_port)
self._terminate = threading.Event()
self._nats_backend_thread = NatsBackendThread(nats_uri)
--
GitLab