From d13f7cdb0dae2fe5e0e7d0a6b143ec9e65cffc24 Mon Sep 17 00:00:00 2001
From: vipeller <51135538+vipeller@users.noreply.github.com>
Date: Thu, 1 Apr 2021 16:38:45 -0700
Subject: [PATCH] Turning of batching for incoming amqp messages to gain faster
 feedback to the sender

---
 .../linkhandlers/ReceivingLinkHandler.cs                      | 4 ++--
 1 file changed, 2 insertions(+), 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
index 11cbcc0ddce..a6a568c2fa8 100644
--- 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
             {