fix bug in client connection establishment, introduced in #82, that c…

…aused slow startup
microsoft · Jan 7, 2022 · 757a7fc · 757a7fc
1 parent 0499ba5
commit 757a7fc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/DurableTask.Netherite/TransportProviders/EventHubs/EventHubsTransport.cs b/src/DurableTask.Netherite/TransportProviders/EventHubs/EventHubsTransport.cs
@@ -446,7 +446,7 @@ async Task ClientEstablishConnectionAsync(int index, PartitionReceiver receiver)
                 this.traceHelper.LogDebug("Client{clientId}.ch{index} establishing connection", Client.GetShortId(this.ClientId), index);
                 // receive a dummy packet to establish connection
                 // (the packet, if any, cannot be for this receiver because it is fresh)
-                await receiver.ReceiveAsync(1);
+                await receiver.ReceiveAsync(1, TimeSpan.FromMilliseconds(1));
             }
             catch (Exception exception)
             {