diff --git a/RabbitMQ.DefaultExchange/Publisher/Program.cs b/RabbitMQ.DefaultExchange/Publisher/Program.cs index a5a7862..80bb3fd 100644 --- a/RabbitMQ.DefaultExchange/Publisher/Program.cs +++ b/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); + } } } }