diff --git a/BMA.EHR.CheckInConsumer/Program.cs b/BMA.EHR.CheckInConsumer/Program.cs index 95dac001..eaba4b4b 100644 --- a/BMA.EHR.CheckInConsumer/Program.cs +++ b/BMA.EHR.CheckInConsumer/Program.cs @@ -45,29 +45,17 @@ consumer.Received += async (model, ea) => var body = ea.Body.ToArray(); var message = Encoding.UTF8.GetString(body); - WriteToConsole($"Received message: {message}"); + //WriteToConsole($"ได้รับคำขอจาก Queue: {message}"); - var success = await CallRestApi(message, httpClient, configuration); - - if (success) - { - channel.BasicAck(ea.DeliveryTag, multiple: false); - WriteToConsole("Message processed successfully"); - } - else - { - channel.BasicNack(ea.DeliveryTag, multiple: false, requeue: false); - WriteToConsole("Message processing failed - message rejected"); - } + await CallRestApi(message, httpClient, configuration); } catch (Exception ex) { WriteToConsole($"Error processing message: {ex.Message}"); - channel.BasicNack(ea.DeliveryTag, multiple: false, requeue: false); } }; -channel.BasicConsume(queue: queue, autoAck: false, consumer: consumer); +channel.BasicConsume(queue: queue, autoAck: true, consumer: consumer); WriteToConsole("Consumer started. Waiting for messages..."); @@ -79,7 +67,7 @@ static void WriteToConsole(string message) Console.WriteLine($"{DateTime.Now:yyyy-MM-dd HH:mm:ss} : {message}"); } -static async Task CallRestApi(string requestData, HttpClient client, IConfiguration configuration) +static async Task CallRestApi(string requestData, HttpClient client, IConfiguration configuration) { try { @@ -91,31 +79,26 @@ static async Task CallRestApi(string requestData, HttpClient client, IConf if (response.IsSuccessStatusCode) { var responseContent = await response.Content.ReadAsStringAsync(); - WriteToConsole($"API Success: {responseContent}"); - return true; + //WriteToConsole($"Success: {responseContent}"); } else { var errorMessage = await response.Content.ReadAsStringAsync(); var res = JsonSerializer.Deserialize(errorMessage); - WriteToConsole($"API Error ({response.StatusCode}): {res?.Message ?? errorMessage}"); - return false; + WriteToConsole($"API Error: {res?.Message ?? "Unknown error"}"); } } catch (HttpRequestException ex) { WriteToConsole($"HTTP Error: {ex.Message}"); - return false; } catch (TaskCanceledException ex) { WriteToConsole($"Timeout: {ex.Message}"); - return false; } catch (Exception ex) { WriteToConsole($"Unexpected Error: {ex.Message}"); - return false; } }