app.py

@@ -40,9 +40,9 @@ if __name__ == "__main__":
     generateduuid = str(uuid.uuid4())
     communicator = Communicator(currentconsumer=KNOWNCONSUMER, uuid=generateduuid)
     LOGGER.debug(f"My uuid is {generateduuid}")
-    messagesender = MessageSender(communicator=communicator, uuid=generateduuid)
     consumerlocator = ConsumerLocator(uuid=generateduuid, communicator=communicator,
-                                      redisconnector=RedisConnector())
+        redisconnector=RedisConnector())
+    messagesender = MessageSender(communicator=communicator)
     consumerlocator.learnconsumerlist()
 
     while True:

messagesender.py

@@ -7,7 +7,6 @@ Message sender component.
 import logging
 import random
 import string
-import json
 from communicator import Communicator
 
 __author__ = "@kovacsbence"
@@ -24,14 +23,13 @@ class MessageSender:
     Component responsible for sending the messages. Requires an instance of :class:`communicator.Communicator`.
     """
 
-    def __init__(self, communicator: Communicator, uuid: str):
+    def __init__(self, communicator: Communicator):
         """**Constructor:**
         Initializes the object.
 
         :param communicator: an instance of :class:`communicator.Communicator`.
         """
         self.communicator = communicator
-        self.uuid = uuid
 
     def randomstring(self, stringlength: int) -> str:
         """Generate a random string of fixed length
@@ -56,4 +54,4 @@ class MessageSender:
             data = self.randomstring(32)
         else:
             data = message
-        self.communicator.sendmessage(json.dumps({"message": data, "uuid": self.uuid}))
+        self.communicator.sendmessage(data)