@@ -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
@@ -464,13 +464,13 @@ namespace Microsoft.Azure.ServiceBus
464464 public override Microsoft.Azure.ServiceBus.ServiceBusConnection ServiceBusConnection { get; }
465465 public string TopicName { get; }
466466 public System.Threading.Tasks.Task CancelScheduledMessageAsync(long sequenceNumber) { }
467- public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.Batch > CreateBatch() { }
467+ public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.MessageBatch > CreateBatch() { }
468468 protected override System.Threading.Tasks.Task OnClosingAsync() { }
469469 public override void RegisterPlugin(Microsoft.Azure.ServiceBus.Core.ServiceBusPlugin serviceBusPlugin) { }
470470 public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
471471 public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
472472 public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
473- public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch ) { }
473+ public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.MessageBatch messageBatch ) { }
474474 public override void UnregisterPlugin(string serviceBusPluginName) { }
475475 }
476476 public enum TransportType
@@ -496,15 +496,6 @@ namespace Microsoft.Azure.ServiceBus
496496}
497497namespace Microsoft.Azure.ServiceBus.Core
498498{
499- [System.Diagnostics.DebuggerDisplayAttribute("{DebuggerDisplay,nq}")]
500- public class Batch : System.IDisposable
501- {
502- public Batch(ulong maximumBatchSize, System.Func<Microsoft.Azure.ServiceBus.Message, System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Message>> pluginsCallback) { }
503- public int Length { get; }
504- public void Dispose() { }
505- public Microsoft.Azure.Amqp.AmqpMessage ToAmqpMessage() { }
506- public System.Threading.Tasks.Task<bool> TryAdd(Microsoft.Azure.ServiceBus.Message message) { }
507- }
508499 public interface IMessageReceiver : Microsoft.Azure.ServiceBus.Core.IReceiverClient, Microsoft.Azure.ServiceBus.IClientEntity
509500 {
510501 long LastPeekedSequenceNumber { get; }
@@ -542,6 +533,13 @@ namespace Microsoft.Azure.ServiceBus.Core
542533 System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message);
543534 System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList);
544535 }
536+ [System.Diagnostics.DebuggerDisplayAttribute("{DebuggerDisplay,nq}")]
537+ public class MessageBatch : System.IDisposable
538+ {
539+ public int Length { get; }
540+ public void Dispose() { }
541+ public System.Threading.Tasks.Task<bool> TryAdd(Microsoft.Azure.ServiceBus.Message message) { }
542+ }
545543 public class MessageReceiver : Microsoft.Azure.ServiceBus.ClientEntity, Microsoft.Azure.ServiceBus.Core.IMessageReceiver, Microsoft.Azure.ServiceBus.Core.IReceiverClient, Microsoft.Azure.ServiceBus.IClientEntity
546544 {
547545 public MessageReceiver(Microsoft.Azure.ServiceBus.ServiceBusConnectionStringBuilder connectionStringBuilder, Microsoft.Azure.ServiceBus.ReceiveMode receiveMode = 0, Microsoft.Azure.ServiceBus.RetryPolicy retryPolicy = null, int prefetchCount = 0) { }
@@ -601,13 +599,13 @@ namespace Microsoft.Azure.ServiceBus.Core
601599 public override Microsoft.Azure.ServiceBus.ServiceBusConnection ServiceBusConnection { get; }
602600 public string TransferDestinationPath { get; }
603601 public System.Threading.Tasks.Task CancelScheduledMessageAsync(long sequenceNumber) { }
604- public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.Batch > CreateBatch() { }
602+ public System.Threading.Tasks.Task<Microsoft.Azure.ServiceBus.Core.MessageBatch > CreateBatch() { }
605603 protected override System.Threading.Tasks.Task OnClosingAsync() { }
606604 public override void RegisterPlugin(Microsoft.Azure.ServiceBus.Core.ServiceBusPlugin serviceBusPlugin) { }
607605 public System.Threading.Tasks.Task<long> ScheduleMessageAsync(Microsoft.Azure.ServiceBus.Message message, System.DateTimeOffset scheduleEnqueueTimeUtc) { }
608606 public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Message message) { }
609607 public System.Threading.Tasks.Task SendAsync(System.Collections.Generic.IList<Microsoft.Azure.ServiceBus.Message> messageList) { }
610- public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.Batch batch ) { }
608+ public System.Threading.Tasks.Task SendAsync(Microsoft.Azure.ServiceBus.Core.MessageBatch messageBatch ) { }
611609 public override void UnregisterPlugin(string serviceBusPluginName) { }
612610 }
613611 public abstract class ServiceBusPlugin
0 commit comments