update ServiveBus Ex DI

TEAMModelOS.SDK/DI/AzureServiceBus/AzureServiceBusExtensions.cs

@@ -21,12 +21,12 @@ namespace TEAMModelOS.SDK.DI
         /// <param name="pathName">QueueName or TopicName</param>
         /// <param name="message">訊息</param>
         /// <returns></returns>
-        public static async Task SendMessageAsync(this ServiceBusClient client, string pathName, string message)
+        public static async Task SendMessageAsync(this ServiceBusClient client, string pathName, ServiceBusMessage message)
         {
             try
             {
                 ServiceBusSender sender = client.CreateSender(pathName);
-                await sender.SendMessageAsync(new ServiceBusMessage(Encoding.UTF8.GetBytes(message)));
+                await sender.SendMessageAsync(message);
             }
             catch
             {
@@ -40,7 +40,7 @@ namespace TEAMModelOS.SDK.DI
         /// <param name="pathName">QueueName or TopicName</param>
         /// <param name="messages">批量訊息</param>
         /// <returns></returns>
-        public static async Task<bool> SendBatchMessageAsync(this ServiceBusClient client, string pathName, IList<string> messages)
+        public static async Task<bool> SendBatchMessageAsync(this ServiceBusClient client, string pathName, IList<ServiceBusMessage> messages)
         {
             try
             {
@@ -48,7 +48,7 @@ namespace TEAMModelOS.SDK.DI
                 ServiceBusMessageBatch messageBatch = await sender.CreateMessageBatchAsync();
                 foreach (var msg in messages)
                 {
-                    if (!messageBatch.TryAddMessage(new ServiceBusMessage(Encoding.UTF8.GetBytes(msg)))) return false;
+                    if (!messageBatch.TryAddMessage(msg)) return false;
                 }
                 await sender.SendMessagesAsync(messageBatch);
                 return true;
@@ -65,12 +65,12 @@ namespace TEAMModelOS.SDK.DI
         /// <param name="pathName">QueueName or TopicName</param>
         /// <param name="message">訊息</param>
         /// <returns>排程訊息的序列號。</returns>
-        public static async Task<long> SendScheduleMessageAsync(this ServiceBusClient client, string pathName, string message, DateTimeOffset scheduleTime)
+        public static async Task<long> SendScheduleMessageAsync(this ServiceBusClient client, string pathName, ServiceBusMessage message, DateTimeOffset scheduleTime)
         {
             try
             {
                 ServiceBusSender sender = client.CreateSender(pathName);
-                return await sender.ScheduleMessageAsync(new ServiceBusMessage(Encoding.UTF8.GetBytes(message)), scheduleTime);
+                return await sender.ScheduleMessageAsync(message, scheduleTime);
             }
             catch
             {
@@ -84,7 +84,7 @@ namespace TEAMModelOS.SDK.DI
         /// <param name="pathName">QueueName or TopicName</param>
         /// <param name="messages">批量訊息</param>
         /// <returns>排程訊息的序列號</returns>
-        public static async Task<long[]> SendScheduleMessagesAsync(this ServiceBusClient client, string pathName, IList<string> messages, DateTimeOffset scheduleTime)
+        public static async Task<long[]> SendScheduleMessagesAsync(this ServiceBusClient client, string pathName, IList<ServiceBusMessage> messages, DateTimeOffset scheduleTime)
         {
             try
             {
@@ -92,7 +92,7 @@ namespace TEAMModelOS.SDK.DI
                 List<ServiceBusMessage> msgs = new List<ServiceBusMessage>() { };
                 foreach (var msg in messages)
                 {
-                    msgs.Add(new ServiceBusMessage(Encoding.UTF8.GetBytes(msg)));
+                    msgs.Add(msg);
                 }
                 return await sender.ScheduleMessagesAsync(msgs, scheduleTime);
             }