Update Program.cs

RabbitMQ.DefaultExchange/Publisher/Program.cs

@@ -1,42 +1,49 @@
-using RabbitMQ.Client;
 using System;
 using System.Text;
 using System.Threading;
+using RabbitMQ.Client;
 
-namespace Publisher
+namespace RabbitMQ.DefaultExchange.Publisher
 {
     class Program
     {
+        private const string QueueName = "km23_default_queue";
+
         static void Main(string[] args)
         {
-            var counter = 0;
-            do
+            var factory = new ConnectionFactory
+            {
+                HostName = "localhost"
+            };
+
+            using var connection = factory.CreateConnection();
+            using var channel = connection.CreateModel();
+
+            channel.QueueDeclare(
+                queue: QueueName,
+                durable: false,
+                exclusive: false,
+                autoDelete: false,
+                arguments: null);
+
+            Console.WriteLine("Publisher started. Press Ctrl+C to stop.");
+
+            int counter = 1;
+
+            while (true)
             {
-                int timeToSleep = new Random().Next(1000, 3000);
-                Thread.Sleep(timeToSleep);
-
-                var factory = new ConnectionFactory() { HostName = "localhost" };
-                using (var connection = factory.CreateConnection())
-                using (var channel = connection.CreateModel())
-                {
-                    channel.QueueDeclare(queue: "dev-queue",
-                                         durable: false,
-                                         exclusive: false,
-                                         autoDelete: false,
-                                         arguments: null);
-
-                    string message = $"Message from publisher N {counter}";
-
-                    var body = Encoding.UTF8.GetBytes(message);
-
-                    channel.BasicPublish(exchange: "",
-                                        routingKey: "dev-queue",
-                                        basicProperties: null,
-                                        body: body);
-
-                    Console.WriteLine($"Message is sent into Default Exchange [N:{counter++}]");
-                }
-            } while (true);
+                string message = $"[{DateTime.Now:HH:mm:ss}] KM-23 lab message #{counter}";
+                var body = Encoding.UTF8.GetBytes(message);
+                channel.BasicPublish(
+                    exchange: "",
+                    routingKey: QueueName,  
+                    basicProperties: null,
+                    body: body);
+
+                Console.WriteLine($"[x] Sent: {message}");
+                counter++;
+                Thread.Sleep(1500);
+            }
         }
     }
 }