Fixes #534 (#536)

Fixes #534 - batching disposition is always set to true with async operations.

Author: SeanFeldman

src/Microsoft.Azure.ServiceBus/Amqp/AmqpMessageConverter.cs

@@ -32,7 +32,7 @@ static class AmqpMessageConverter
         const string DateTimeOffsetName = AmqpConstants.Vendor + ":datetime-offset";
         const int GuidSize = 16;
 
-        public static AmqpMessage BatchSBMessagesAsAmqpMessage(IEnumerable<SBMessage> sbMessages, bool batchable)
+        public static AmqpMessage BatchSBMessagesAsAmqpMessage(IEnumerable<SBMessage> sbMessages)
         {
             if (sbMessages == null)
             {
@@ -66,7 +66,7 @@ public static AmqpMessage BatchSBMessagesAsAmqpMessage(IEnumerable<SBMessage> sb
 
             if (messageCount == 1 && firstAmqpMessage != null)
             {
-                firstAmqpMessage.Batchable = batchable;
+                firstAmqpMessage.Batchable = true;
                 return firstAmqpMessage;
             }
 
@@ -94,7 +94,7 @@ public static AmqpMessage BatchSBMessagesAsAmqpMessage(IEnumerable<SBMessage> sb
                     firstMessage.ViaPartitionKey;
             }
 
-            amqpMessage.Batchable = batchable;
+            amqpMessage.Batchable = true;
             return amqpMessage;
         }
 

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

@@ -92,7 +92,7 @@ public MessageSender(
             TransportType transportType = TransportType.Amqp,
             RetryPolicy retryPolicy = null)
             : this(entityPath, null, null, new ServiceBusConnection(endpoint, transportType, retryPolicy) {TokenProvider = tokenProvider}, null, retryPolicy)
-        {            
+        {
             this.OwnsConnection = true;
         }
 
@@ -119,9 +119,9 @@ public MessageSender(
         /// <param name="viaEntityPath">The first destination of the message.</param>
         /// <param name="retryPolicy">The <see cref="RetryPolicy"/> that will be used when communicating with Service Bus. Defaults to <see cref="RetryPolicy.Default"/></param>
         /// <remarks>
-        /// This is mainly to be used when sending messages in a transaction. 
+        /// This is mainly to be used when sending messages in a transaction.
         /// When messages need to be sent across entities in a single transaction, this can be used to ensure
-        /// all the messages land initially in the same entity/partition for local transactions, and then 
+        /// all the messages land initially in the same entity/partition for local transactions, and then
         /// let service bus handle transferring the message to the actual destination.
         /// </remarks>
         public MessageSender(
@@ -524,7 +524,7 @@ async Task<IList<Message>> ProcessMessages(IList<Message> messageList)
         async Task OnSendAsync(IList<Message> messageList)
         {
             var timeoutHelper = new TimeoutHelper(this.OperationTimeout, true);
-            using (var amqpMessage = AmqpMessageConverter.BatchSBMessagesAsAmqpMessage(messageList, true))
+            using (var amqpMessage = AmqpMessageConverter.BatchSBMessagesAsAmqpMessage(messageList))
             {
                 SendingAmqpLink amqpLink = null;
                 try