diff --git a/components/shared/dse_shared_libs/message_broker_wrapper.py b/components/shared/dse_shared_libs/message_broker_wrapper.py
index bb48033..07b3a79 100644
--- a/components/shared/dse_shared_libs/message_broker_wrapper.py
+++ b/components/shared/dse_shared_libs/message_broker_wrapper.py
@@ -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)