From a7b90d86f68ab3a2f4cd00c8145e5508bf0f6007 Mon Sep 17 00:00:00 2001 From: Daniel McKnight Date: Tue, 28 Nov 2023 15:08:13 -0800 Subject: [PATCH] Remove bus kwarg handling --- neon_messagebus_mq_connector/controller.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/neon_messagebus_mq_connector/controller.py b/neon_messagebus_mq_connector/controller.py index 7b71627..2c9c57e 100644 --- a/neon_messagebus_mq_connector/controller.py +++ b/neon_messagebus_mq_connector/controller.py @@ -51,8 +51,7 @@ class ChatAPIProxy(MQConnector): Proxy module for establishing connection between Neon Core and an MQ Broker """ - def __init__(self, config: dict, service_name: str, - bus: MessageBusClient = None): + def __init__(self, config: dict, service_name: str): config = config or Configuration() mq_config = config.get("MQ", config) super().__init__(mq_config, service_name) @@ -62,7 +61,6 @@ def __init__(self, config: dict, service_name: str, "1.0.0") self.bus_config = config.get("MESSAGEBUS") self._vhost = '/neon_chat_api' - self._bus = bus self.connect_bus() self.register_consumer(name=f'neon_api_request_{self.service_id}', vhost=self.vhost,