Skip to content

Commit

Permalink
Remove bus kwarg handling
Browse files Browse the repository at this point in the history
  • Loading branch information
NeonDaniel committed Nov 28, 2023
1 parent d34ce90 commit a7b90d8
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions neon_messagebus_mq_connector/controller.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand All @@ -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,
Expand Down

0 comments on commit a7b90d8

Please sign in to comment.