diff --git a/src/common/message_broker/backend/nats/NatsBackend.py b/src/common/message_broker/backend/nats/NatsBackend.py
index 35de3acb3043f5b0a7a08cb9a441bffe8af3462e..bcbf2a721e5d41ef122f239ee5a536eb575edcbe 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)