zenon/dse-assignment
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

added comments

Browse Source
This commit is contained in:
Marco Zeisler 2021-05-28 21:29:08 +02:00
parent 3880ec0d54
commit 9b4e334f9a
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
components/shared/dse_shared_libs/message_broker_wrapper.py
View File

@ -26,6 +26,7 @@ class MBWrapper:
verbose: bool = False):
assert exchange_name, 'Please define an exchange name'
# append a connection to the logging broker, if it isn't the logging broker itself
if exchange_name != 'logger':
self._logger = MBWrapper(exchange_name='logger')
self._logger.setup_sender()
@ -53,6 +54,9 @@ class MBWrapper:
'Please setup MBWrapper with "on response" self.callback which can handle a byte string as input.'
def consumer():
"""
Consumer thread which waits for incoming messages, invokes self._receive
"""
self._setup_channel()
result = self._channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue
@ -73,6 +77,8 @@ class MBWrapper:
message = str(message).encode()
self._channel.basic_publish(exchange=self.exchange_name, routing_key='', body=message)
self.print("[{}] Sent {}".format(self.exchange_name, message))
# has a logger IFF not 'logger' as exchange name -> forwards everything to logger exchange, too
if self.__getattribute__('_logger'):
# print('logging')
self._logger.send(message)