hrms-bangkok/hrms-api-backend
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 7 Wiki Activity Actions

change comsumer queue

Browse source
This commit is contained in:
Suphonchai Phoonsawat 2024-12-13 10:35:05 +07:00
parent 5e891b96b7
commit db2dd8b6bc
2 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
BMA.EHR.CheckInConsumer/Program.cs
View file

@ -16,6 +16,7 @@ WriteToConsole("Consumer Start!");
var host = configuration["Rabbit:Host"] ?? ""; var host = configuration["Rabbit:Host"] ?? "";
var user = configuration["Rabbit:User"] ?? ""; var user = configuration["Rabbit:User"] ?? "";
var pass = configuration["Rabbit:Password"] ?? ""; var pass = configuration["Rabbit:Password"] ?? "";
var queue = configuration["Rabbit:Queue"] ?? "basic-queue";
// create connection // create connection
var factory = new ConnectionFactory() var factory = new ConnectionFactory()
@ -29,7 +30,8 @@ var factory = new ConnectionFactory()
using var connection = factory.CreateConnection(); using var connection = factory.CreateConnection();
using var channel = connection.CreateModel(); using var channel = connection.CreateModel();
channel.QueueDeclare(queue: "bma-checkin-queue", durable: true, exclusive: false, autoDelete: false, arguments: null); //channel.QueueDeclare(queue: "bma-checkin-queue", durable: true, exclusive: false, autoDelete: false, arguments: null);
channel.QueueDeclare(queue: queue, durable: true, exclusive: false, autoDelete: false, arguments: null);
var consumer = new EventingBasicConsumer(channel); var consumer = new EventingBasicConsumer(channel);
@ -59,7 +61,8 @@ consumer.Received += async (model, ea) =>
//WriteToConsole($"ตอบกลับจาก REST API: {JsonConvert.SerializeObject(item)}"); //WriteToConsole($"ตอบกลับจาก REST API: {JsonConvert.SerializeObject(item)}");
}; };
channel.BasicConsume(queue: "bma-checkin-queue", autoAck: true, consumer: consumer); //channel.BasicConsume(queue: "bma-checkin-queue", autoAck: true, consumer: consumer);
channel.BasicConsume(queue: queue, autoAck: true, consumer: consumer);
//Console.WriteLine("\nPress 'Enter' to exit the process..."); //Console.WriteLine("\nPress 'Enter' to exit the process...");

3
BMA.EHR.CheckInConsumer/appsettings.json
View file

@ -2,7 +2,8 @@
"Rabbit": { "Rabbit": {
"Host": "192.168.1.40", "Host": "192.168.1.40",
"User": "admin", "User": "admin",
"Password": "Test123456" "Password": "Test123456",
"Queue": "bma-checkin-queue"
}, },
"API": "https://localhost:7283/api/v1" "API": "https://localhost:7283/api/v1"
} }