From 7ef72a04460076aa655035a18484b519ab949f20 Mon Sep 17 00:00:00 2001
From: ruinivist <ruinivist@proton.me>
Date: Tue, 14 Apr 2026 21:54:20 +0000
Subject: [PATCH] make producer infi

---
 producer.py | 25 ++++++++++++++-----------
 1 file changed, 14 insertions(+), 11 deletions(-)

diff --git a/producer.py b/producer.py
index 21703e4..c10eb30 100644
--- a/producer.py
+++ b/producer.py
@@ -1,4 +1,5 @@
 import pika
+import time
 import json
 
 conn = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
@@ -21,18 +22,20 @@ orders = [
         "should_fail": False, "retry_count": 0},
 ]
 
-for order in orders:
-    body = json.dumps(order)
-    ch.basic_publish(
-        exchange="orders.x",
-        routing_key="order.created",  # as in the bindings
-        body=body,
-        properties=pika.BasicProperties(
-            delivery_mode=2,  # persistent msg, committed to disk before ack
-            content_type="application/json"
+while True:
+    for order in orders:
+        time.sleep(1)
+        body = json.dumps(order)
+        ch.basic_publish(
+            exchange="orders.x",
+            routing_key="order.created",  # as in the bindings
+            body=body,
+            properties=pika.BasicProperties(
+                delivery_mode=2,  # persistent msg, committed to disk before ack
+                content_type="application/json"
+            )
         )
-    )
 
-    print(f"published order {order['order_id']}")
+        print(f"published order {order['order_id']}")
 
 conn.close()