issue-304 - solve problem with memory leak. Added closing connection (#306)

MikhailTushev · AzureAD\MikhailTushev · web-flow · commit 7b203f12cd62 · 2023-09-20T15:06:31.000+02:00
Co-authored-by: AzureAD\MikhailTushev &lt;mikhail.tushev@itl.team&gt;
diff --git a/RabbitMQ.Stream.Client/RoutingClient.cs b/RabbitMQ.Stream.Client/RoutingClient.cs
@@ -92,6 +92,9 @@ private static async Task<IClient> LookupConnection(
                 advertisedPort = GetPropertyValue(client.ConnectionProperties, "advertised_port");
                 if (attemptNo > maxAttempts)
                 {
+                    await client.Close($"advertised_host or advertised_port doesn't match after {attemptNo} attempts")
+                        .ConfigureAwait(false);
+
                     throw new RoutingClientException(
                         $"Could not find broker ({broker.Host}:{broker.Port}) after {maxAttempts} attempts");
                 }

Original file line number	Diff line number	Diff line change
`@@ -92,6 +92,9 @@ private static async Task<IClient> LookupConnection(`
`92`	`92`	`advertisedPort = GetPropertyValue(client.ConnectionProperties, "advertised_port");`
`93`	`93`	`if (attemptNo > maxAttempts)`
`94`	`94`	`{`
	`95`	`+ await client.Close($"advertised_host or advertised_port doesn't match after {attemptNo} attempts")`
	`96`	`+ .ConfigureAwait(false);`
	`97`	`+`
`95`	`98`	`throw new RoutingClientException(`
`96`	`99`	`$"Could not find broker ({broker.Host}:{broker.Port}) after {maxAttempts} attempts");`
`97`	`100`	`}`