л/р 4 Юденичева Дарья

tasks/yudenicheva-ds/lab_4/python4Lab/Lab4MainTask/Publisher.py

@@ -0,0 +1,19 @@
+import pika
+import time
+import random
+
+collection = ["Application for general business expenses", "The contract is completed", "Enrollment order completed", "Student enrolled"]
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='Agreements', exchange_type='fanout')
+
+while True:
+    message = f"Message: {random.choice(collection)}"
+
+    channel.basic_publish(exchange='Agreements', routing_key='', body=message)
+
+    time.sleep(1)
+
+connection.close()