Skip to content

Commit 8639429

Browse files
authored
[Service Bus] Fix Batch Delete Limit (#50151)
* [Service Bus] Fix Batch Delete Limit The focus of these changes is to fix the message limit applied to the preview batch delete feature, as the service thresholds have changed.
1 parent 96222a4 commit 8639429

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

sdk/servicebus/Azure.Messaging.ServiceBus/src/Receiver/ServiceBusReceiver.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ namespace Azure.Messaging.ServiceBus
3535
public class ServiceBusReceiver : IAsyncDisposable
3636
{
3737
/// <summary>The maximum number of messages to delete in a single batch. This cap is established and enforced by the service.</summary>
38-
internal const int MaxDeleteMessageCount = 4000;
38+
internal const int MaxDeleteMessageCount = 500;
3939

4040
/// <summary>The set of default options to use for initialization when no explicit options were provided.</summary>
4141
private static ServiceBusReceiverOptions s_defaultOptions;

sdk/servicebus/Azure.Messaging.ServiceBus/tests/Receiver/ReceiverTests.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -648,7 +648,7 @@ public async Task PurgeMessagesForDateEvaluatesReturnedCount()
648648
[Test]
649649
public async Task DeleteMessagesForCountPassesTheCurrentDate()
650650
{
651-
var expectedCount = 2000;
651+
var expectedCount = 400;
652652
var mockConnection = ServiceBusTestUtilities.CreateMockConnection();
653653
var mockTransportReceiver = new Mock<TransportReceiver>();
654654

@@ -696,8 +696,8 @@ public async Task DeleteMessagesPassesParametersToTransport()
696696
{
697697
using var cancellationSource = new CancellationTokenSource();
698698

699-
var requestedCount = 2500;
700-
var expectedCount = 2000;
699+
var requestedCount = 500;
700+
var expectedCount = 400;
701701
var expectedDate = new DateTimeOffset(2015, 10, 27, 0, 0, 0, 0, TimeSpan.Zero);
702702
var mockConnection = ServiceBusTestUtilities.CreateMockConnection();
703703
var mockTransportReceiver = new Mock<TransportReceiver>();

0 commit comments

Comments
 (0)