Turning of batching for incoming amqp messages to gain faster feedbac…

…k to the sender
vipeller · Apr 1, 2021 · d13f7cd · d13f7cd
1 parent 028e4a0
commit d13f7cd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Amqp/linkhandlers/ReceivingLinkHandler.cs b/edge-hub/core/src/Microsoft.Azure.Devices.Edge.Hub.Amqp/linkhandlers/ReceivingLinkHandler.cs
@@ -85,12 +85,12 @@ internal async Task ProcessMessageAsync(AmqpMessage amqpMessage)
             try
             {
                 await this.OnMessageReceived(amqpMessage);
-                ((IReceivingAmqpLink)this.Link).DisposeMessage(amqpMessage, AmqpConstants.AcceptedOutcome, true, true);
+                ((IReceivingAmqpLink)this.Link).DisposeMessage(amqpMessage, AmqpConstants.AcceptedOutcome, true, false);
             }
             catch (Exception e) when (!e.IsFatal())
             {
                 Events.ErrorProcessingMessage(e, this);
-                ((IReceivingAmqpLink)this.Link).DisposeMessage(amqpMessage, AmqpConstants.RejectedOutcome, true, true);
+                ((IReceivingAmqpLink)this.Link).DisposeMessage(amqpMessage, AmqpConstants.RejectedOutcome, true, false);
             }
             finally
             {