changed rabbit client config name

MacherLabs · Jan 13, 2021 · 1931a5d · 1931a5d
1 parent bf97d4d
commit 1931a5d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/eazyserver/core/manager.py b/src/eazyserver/core/manager.py
@@ -21,7 +21,7 @@ def __init__(self, **kwargs):
 		self.connector_type = kwargs.get('connector_type','kafka')
 		self.kafka_client_type = kwargs.get('kafka_client_type',None)
 		self.kafka_client_config = kwargs.get('kafka_client_config',None)
-		self.client_config=kwargs.get('client_config',None)
+		self.rabbit_client_config=kwargs.get('rabbit_client_config',None)
 
 
 		self.pid = os.getpid()
@@ -39,7 +39,7 @@ def __init__(self, **kwargs):
 			self.connected_behaviour = RabbitMqConnector(
 				self.behaviour, 
 				on_exit=self.stop,
-				**self.client_config)
+				**self.self.rabbit_client_config)
 
 		self.signal_map = kwargs.get('signal_map', {})