change: Change Consumer Queue Name

This commit is contained in:
Suphonchai Phoonsawat 2024-08-20 11:57:32 +07:00
parent f5355728ab
commit f8c62a1cde

View file

@ -29,7 +29,7 @@ var factory = new ConnectionFactory()
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();
channel.QueueDeclare(queue: "checkin-queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
channel.QueueDeclare(queue: "bma-checkin-queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
var consumer = new EventingBasicConsumer(channel);
@ -59,7 +59,7 @@ consumer.Received += async (model, ea) =>
//WriteToConsole($"ตอบกลับจาก REST API: {JsonConvert.SerializeObject(item)}");
};
channel.BasicConsume(queue: "checkin-queue", autoAck: true, consumer: consumer);
channel.BasicConsume(queue: "bma-checkin-queue", autoAck: true, consumer: consumer);
//Console.WriteLine("\nPress 'Enter' to exit the process...");