finalized emqx demo

andreiionutdamian · Feb 19, 2024 · 26231f7 · 26231f7
1 parent 5253320
commit 26231f7
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/labs/labs-internal/emqx/app/src/__pycache__/base.cpython-310.pyc b/labs/labs-internal/emqx/app/src/__pycache__/base.cpython-310.pyc
diff --git a/labs/labs-internal/emqx/app/src/publisher.py b/labs/labs-internal/emqx/app/src/publisher.py
@@ -24,6 +24,7 @@ def __init__(self, *args, **kwargs):
 
   def publish_messages(self):
     """Publish messages with a specific structure."""
+    self.P("Starting publisher thread {} ...".format(self.thread_id))
     while True:
       self.count += 1
       payload = json.dumps({
@@ -38,8 +39,8 @@ def publish_messages(self):
 
   def run(self):
     """Run the publisher."""
-    thread = threading.Thread(target=self.publish_messages)
-    thread.start()
+    self.thread = threading.Thread(target=self.publish_messages)
+    self.thread.start()
     return
 
 if __name__ == '__main__':

diff --git a/labs/labs-internal/emqx/app/src/reader.py b/labs/labs-internal/emqx/app/src/reader.py
@@ -34,6 +34,7 @@ def display_stats(self, ):
     """Periodically display message stats."""
     while True:
       for sender, sum_ in self.messages.items():
+        self.P("----------------------------------------")
         self.P(f"{sender} -> sum -> {sum_} (id: {self.counters[sender]})")
       time.sleep(10)  # Adjust as necessary
     return