@@ -230,7 +230,7 @@ namespace Microsoft.Azure.ServiceBus
230230 public System.Threading.Tasks.Task AbandonAsync(string lockToken, System.Collections.Generic.IDictionary<string, object> propertiesToModify = null) { }
231231 public System.Threading.Tasks.Task CancelScheduledMessageAsync(long sequenceNumber) { }
232232 public System.Threading.Tasks.Task CompleteAsync(string lockToken) { }
233- public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.Batch > CreateBatch() { }
233+ public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.MessageBatch > CreateBatch() { }
234234 public System.Threading.Tasks.Task DeadLetterAsync(string lockToken, System.Collections.Generic.IDictionary<string, object> propertiesToModify = null) { }
235235 public System.Threading.Tasks.Task DeadLetterAsync(string lockToken, string deadLetterReason, string deadLetterErrorDescription = null) { }
236236 protected override System.Threading.Tasks.Task OnClosingAsync() { }
@@ -242,7 +242,7 @@ namespace Microsoft.Azure.ServiceBus
242242 public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
243243 public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
244244 public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
245- public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch ) { }
245+ public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.MessageBatch messageBatch ) { }
246246 public override void UnregisterPlugin(string serviceBusPluginName) { }
247247 }
248248 public sealed class QuotaExceededException : Microsoft.Azure.ServiceBus.ServiceBusException
@@ -459,13 +459,13 @@ namespace Microsoft.Azure.ServiceBus
459459 public override Microsoft.Azure.ServiceBus.ServiceBusConnection ServiceBusConnection { get; }
460460 public string TopicName { get; }
461461 public System.Threading.Tasks.Task CancelScheduledMessageAsync(long sequenceNumber) { }
462- public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.Batch > CreateBatch() { }
462+ public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.MessageBatch > CreateBatch() { }
463463 protected override System.Threading.Tasks.Task OnClosingAsync() { }
464464 public override void RegisterPlugin(Microsoft.Azure.ServiceBus.Core.ServiceBusPlugin serviceBusPlugin) { }
465465 public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
466466 public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
467467 public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
468- public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch ) { }
468+ public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.MessageBatch messageBatch ) { }
469469 public override void UnregisterPlugin(string serviceBusPluginName) { }
470470 }
471471 public enum TransportType
@@ -491,15 +491,6 @@ namespace Microsoft.Azure.ServiceBus
491491}
492492namespace Microsoft.Azure.ServiceBus.Core
493493{
494- [System.Diagnostics.DebuggerDisplayAttribute("{DebuggerDisplay,nq}")]
495- public class Batch : System.IDisposable
496- {
497- public Batch(ulong maximumBatchSize, System.Func<Microsoft.Azure.ServiceBus.Message, System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Message>> pluginsCallback) { }
498- public int Length { get; }
499- public void Dispose() { }
500- public Microsoft.Azure.Amqp.AmqpMessage ToAmqpMessage() { }
501- public System.Threading.Tasks.Task<bool> TryAdd(Microsoft.Azure.ServiceBus.Message message) { }
502- }
503494 public interface IMessageReceiver : Microsoft.Azure.ServiceBus.Core.IReceiverClient, Microsoft.Azure.ServiceBus.IClientEntity
504495 {
505496 long LastPeekedSequenceNumber { get; }
@@ -537,6 +528,13 @@ namespace Microsoft.Azure.ServiceBus.Core
537528 System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message);
538529 System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList);
539530 }
531+ [System.Diagnostics.DebuggerDisplayAttribute("{DebuggerDisplay,nq}")]
532+ public class MessageBatch : System.IDisposable
533+ {
534+ public int Length { get; }
535+ public void Dispose() { }
536+ public System.Threading.Tasks.Task<bool> TryAdd(Microsoft.Azure.ServiceBus.Message message) { }
537+ }
540538 public class MessageReceiver : Microsoft.Azure.ServiceBus.ClientEntity, Microsoft.Azure.ServiceBus.Core.IMessageReceiver, Microsoft.Azure.ServiceBus.Core.IReceiverClient, Microsoft.Azure.ServiceBus.IClientEntity
541539 {
542540 public MessageReceiver(Microsoft.Azure.ServiceBus.ServiceBusConnectionStringBuilder connectionStringBuilder, Microsoft.Azure.ServiceBus.ReceiveMode receiveMode = 0, Microsoft.Azure.ServiceBus.RetryPolicy retryPolicy = null, int prefetchCount = 0) { }
@@ -596,13 +594,13 @@ namespace Microsoft.Azure.ServiceBus.Core
596594 public override Microsoft.Azure.ServiceBus.ServiceBusConnection ServiceBusConnection { get; }
597595 public string TransferDestinationPath { get; }
598596 public System.Threading.Tasks.Task CancelScheduledMessageAsync(long sequenceNumber) { }
599- public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.Batch > CreateBatch() { }
597+ public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.MessageBatch > CreateBatch() { }
600598 protected override System.Threading.Tasks.Task OnClosingAsync() { }
601599 public override void RegisterPlugin(Microsoft.Azure.ServiceBus.Core.ServiceBusPlugin serviceBusPlugin) { }
602600 public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
603601 public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
604602 public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
605- public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch ) { }
603+ public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.MessageBatch messageBatch ) { }
606604 public override void UnregisterPlugin(string serviceBusPluginName) { }
607605 }
608606 public abstract class ServiceBusPlugin
0 commit comments