Adding batched send to QueueClient and TopicClient

Author: SeanFeldman

src/Microsoft.Azure.ServiceBus/Core/ISenderClient.cs

@@ -25,6 +25,12 @@ public interface ISenderClient : IClientEntity
         /// </summary>
         Task SendAsync(IList<Message> messageList);
 
+// TODO: extract method into this interface for the next major version
+//        /// <summary>
+//        /// Sends a <see cref="Batch"/> of messages to Service Bus.
+//        /// </summary>
+//        Task SendAsync(Batch batch);
+
         /// <summary>
         /// Schedules a message to appear on Service Bus.
         /// </summary>

src/Microsoft.Azure.ServiceBus/Core/MessageSender.cs

@@ -267,6 +267,10 @@ public async Task SendAsync(IList<Message> messageList)
 
             MessagingEventSource.Log.MessageSendStop(this.ClientId);
         }
+
+        /// <summary>
+        /// Sends a <see cref="Batch"/> of messages to Service Bus.
+        /// </summary>
         public async Task SendAsync(Batch batch)
         {
             this.ThrowIfClosed();

src/Microsoft.Azure.ServiceBus/QueueClient.cs

@@ -89,7 +89,7 @@ public QueueClient(string connectionString, string entityPath, ReceiveMode recei
             {
                 throw Fx.Exception.ArgumentNullOrWhiteSpace(connectionString);
             }
-            
+
             this.OwnsConnection = true;
         }
 
@@ -328,7 +328,7 @@ internal SessionPumpHost SessionPumpHost
                 return this.sessionPumpHost;
             }
         }
-        
+
         ICbsTokenProvider CbsTokenProvider { get; }
 
         /// <summary>
@@ -349,6 +349,16 @@ public Task SendAsync(IList<Message> messageList)
             return this.InnerSender.SendAsync(messageList);
         }
 
+        /// <summary>
+        /// Sends a <see cref="Batch"/> of messages to Service Bus.
+        /// </summary>
+        public Task SendAsync(Batch batch)
+        {
+            this.ThrowIfClosed();
+
+            return this.innerSender.SendAsync(batch);
+        }
+
         /// <summary>
         /// Completes a <see cref="Message"/> using its lock token. This will delete the message from the queue.
         /// </summary>

src/Microsoft.Azure.ServiceBus/TopicClient.cs

@@ -164,7 +164,7 @@ internal MessageSender InnerSender
                 return this.innerSender;
             }
         }
-        
+
         ICbsTokenProvider CbsTokenProvider { get; }
 
         /// <summary>
@@ -184,6 +184,16 @@ public Task SendAsync(IList<Message> messageList)
             return this.InnerSender.SendAsync(messageList);
         }
 
+        /// <summary>
+        /// Sends a <see cref="Batch"/> of messages to Service Bus.
+        /// </summary>
+        public Task SendAsync(Batch batch)
+        {
+            this.ThrowIfClosed();
+
+            return this.innerSender.SendAsync(batch);
+        }
+
         /// <summary>
         /// Schedules a message to appear on Service Bus at a later time.
         /// </summary>

test/Microsoft.Azure.ServiceBus.UnitTests/API/ApiApprovals.ApproveAzureServiceBus.approved.txt

@@ -238,6 +238,7 @@ namespace Microsoft.Azure.ServiceBus
         public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
         public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
         public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
+        public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch) { }
         public override void UnregisterPlugin(string serviceBusPluginName) { }
     }
     public sealed class QuotaExceededException : Microsoft.Azure.ServiceBus.ServiceBusException
@@ -453,6 +454,7 @@ namespace Microsoft.Azure.ServiceBus
         public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
         public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
         public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
+        public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch) { }
         public override void UnregisterPlugin(string serviceBusPluginName) { }
     }
     public enum TransportType