Differences

This shows you the differences between two versions of the page.

--- tanszek:oktatas:iss_t:rabbitmq [2024/04/22 08:24] – knehez
+++ tanszek:oktatas:iss_t:rabbitmq [2024/04/22 08:49] (current) – knehez
@@ Line 3: / Line 3: @@
 We send states to a message queue named 'qualityQueue', which stores simple status messages of a quality assurance system. Create a multi-component application that communicates with the message queue through two clients in the following way:
-  - The first client connects to the sensor placed on the measuring machine and randomly sends GOOD, EXCELLENT, and WRONG messages to the 'qualityQueue' message queue every second.
+  - The first component connects to the sensor placed on the measuring machine and randomly sends **GOOD**, **EXCELLENT**, and **WRONG** messages to the '**qualityQueue**' message queue every second.
-  - Create a component that reads and collects the 'GOOD', 'EXCELLENT', and 'WRONG' messages from the qualityQueue queue. After receiving 10 identical messages, it sends a message to the 'qualityStatistics' queue indicating that it has processed 10 messages of a certain quality.
+  - Create a component that reads and collects the '**GOOD**', '**EXCELLENT**', and '**WRONG**' messages from the qualityQueue queue. After receiving 10 identical messages, it sends a message to the '**qualityStatistics**' queue indicating that it has processed 10 messages of a certain quality.
-  - Create a second client that reads the statistics from the 'qualityStatistics' queue and prints to the console, for example, '10 'WRONG' messages has been processed'.
+  - Create a second component that reads the statistics from the '**qualityStatistics**' queue and prints to the console, for example, '10 'WRONG' messages has been processed'.
 <mermaid>
@@ Line 150: / Line 150: @@
 def callback(ch, method, properties, body):
     message = body.decode()
+    print('-----------------------------')
     print(f'{message}')
     ch.basic_ack(delivery_tag=method.delivery_tag)