From 5a2d6f0e2b035a5d4171fce7cc4e05995de8351f Mon Sep 17 00:00:00 2001 From: Daniel McKnight Date: Wed, 26 Jul 2023 14:00:51 -0700 Subject: [PATCH] Cleanup changes --- neon_mq_connector/connector.py | 33 ++++++++++++++++----------------- 1 file changed, 16 insertions(+), 17 deletions(-) diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py index e737fab..dc5b786 100644 --- a/neon_mq_connector/connector.py +++ b/neon_mq_connector/connector.py @@ -218,16 +218,16 @@ def __basic_configurable_properties(self) -> Dict[str, Any]: self.service_configurable_properties() """ return { - 'sync_period': 10, # in seconds - 'observe_period': 20, # in seconds - 'vhost_prefix': '', # Could be used for scalability purposes - 'default_testing_prefix': 'test', - 'testing_envs': (f'{self.service_name.upper()}_TESTING', - 'MQ_TESTING',), # order matters - 'testing_prefix_envs': (f'{self.service_name.upper()}' - f'_TESTING_PREFIX', - 'MQ_TESTING_PREFIX',) # order matters - } + 'sync_period': 10, # in seconds + 'observe_period': 20, # in seconds + 'vhost_prefix': '', # Could be used for scalability purposes + 'default_testing_prefix': 'test', + 'testing_envs': (f'{self.service_name.upper()}_TESTING', + 'MQ_TESTING',), # order matters + 'testing_prefix_envs': (f'{self.service_name.upper()}' + f'_TESTING_PREFIX', + 'MQ_TESTING_PREFIX',) # order matters + } @property def service_configurable_properties(self) -> Dict[str, Any]: @@ -450,13 +450,12 @@ def send_message(self, else: LOG.debug(f'Sending {exchange_type} request to exchange ' f'{exchange}') - msg_id = self.emit_mq_message( - mq_conn, - queue=queue, - request_data=request_data, - exchange=exchange, - exchange_type=exchange_type, - expiration=expiration) + msg_id = self.emit_mq_message(mq_conn, + queue=queue, + request_data=request_data, + exchange=exchange, + exchange_type=exchange_type, + expiration=expiration) LOG.info(f'Message propagated, id={msg_id}') return msg_id