GoldenPogacsa/producer
GoldenPogacsa/producer
Archived
7
0
Fork 0
Code Issues Pull Requests Releases Activity

send uuid with message

Browse Source
This commit is contained in:
Torma Kristóf 2020-04-17 16:59:35 +02:00
parent eff5f4191c
commit 03082b346d
Signed by: tormakris
GPG Key ID: DC83C4F2C41B1047
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app.py
View File

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

6
messagesender.py
View File

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