Adding IdleConnectionTimeout for AMQP (#15926)

Azure · Oct 13, 2020 · 51f9fad · 51f9fad
1 parent b0ea662
commit 51f9fad
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/sdk/eventhub/Microsoft.Azure.EventHubs/src/Amqp/AmqpClientConstants.cs b/sdk/eventhub/Microsoft.Azure.EventHubs/src/Amqp/AmqpClientConstants.cs
@@ -85,5 +85,6 @@ class AmqpClientConstants
 
         // Miscellaneous 
         public const int AmqpSessionTimeoutInSeconds = 30;
+        public static TimeSpan ConnectionIdleTimeout = TimeSpan.FromMinutes(1);
     }
 }
diff --git a/sdk/eventhub/Microsoft.Azure.EventHubs/src/Amqp/AmqpEventHubClient.cs b/sdk/eventhub/Microsoft.Azure.EventHubs/src/Amqp/AmqpEventHubClient.cs
@@ -209,7 +209,8 @@ static AmqpConnectionSettings CreateAmqpConnectionSettings(uint maxFrameSize, st
             {
                 MaxFrameSize = maxFrameSize,
                 ContainerId = containerId,
-                HostName = hostName
+                HostName = hostName,
+                IdleTimeOut = (uint)AmqpClientConstants.ConnectionIdleTimeout.TotalMilliseconds
             };
 
             ClientInfo.Add(connectionSettings);