From e9194b82472637f2228abbb2e4329cb052df1f91 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=98=93=E7=A3=8A?= <jqrddd@163.com>
Date: Fri, 18 Oct 2024 13:58:57 +0800
Subject: [PATCH] optimize TwilioMessageQueueService.cs

optimize TwilioMessageQueueService.cs
---
 .../Services/TwilioMessageQueueService.cs     | 27 ++++++++++---------
 1 file changed, 15 insertions(+), 12 deletions(-)

diff --git a/src/Plugins/BotSharp.Plugin.Twilio/Services/TwilioMessageQueueService.cs b/src/Plugins/BotSharp.Plugin.Twilio/Services/TwilioMessageQueueService.cs
index 33cf800d..fb215e71 100644
--- a/src/Plugins/BotSharp.Plugin.Twilio/Services/TwilioMessageQueueService.cs
+++ b/src/Plugins/BotSharp.Plugin.Twilio/Services/TwilioMessageQueueService.cs
@@ -28,19 +28,22 @@ namespace BotSharp.Plugin.Twilio.Services
             await foreach (var message in _queue.Reader.ReadAllAsync(stoppingToken))
             {
                 await _throttler.WaitAsync(stoppingToken);
-                try
+                _ = Task.Run(async () =>
                 {
-                    Console.WriteLine($"Start processing {message}.");
-                    await ProcessUserMessageAsync(message);
-                }
-                catch (Exception ex)
-                {
-                    Console.WriteLine($"Processing {message} failed due to {ex.Message}.");
-                }
-                finally
-                {
-                    _throttler.Release();
-                }
+                    try
+                    {
+                        Console.WriteLine($"Start processing {message}.");
+                        await ProcessUserMessageAsync(message);
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine($"Processing {message} failed due to {ex.Message}.");
+                    }
+                    finally
+                    {
+                        _throttler.Release();
+                    }
+                });
             }
         }