Fixing Endpoint passed to StreamSystem

TroelsL · TroelsL · commit 748cc9d93c74 · 2023-09-25T23:02:22.000+02:00
diff --git a/RabbitMQ.Stream.Client/StreamSystem.cs b/RabbitMQ.Stream.Client/StreamSystem.cs
@@ -66,12 +66,13 @@ public static async Task<StreamSystem> Create(StreamSystemConfig config, ILogger
             {
                 try
                 {
-                    var client = await Client.Create(clientParams with { Endpoint = endPoint }, logger)
+                    var paramsWithEndPoint = clientParams with { Endpoint = endPoint };
+                    var client = await Client.Create(paramsWithEndPoint, logger)
                         .ConfigureAwait(false);
                     if (!client.IsClosed)
                     {
                         logger?.LogDebug("Client connected to {@EndPoint}", endPoint);
-                        return new StreamSystem(clientParams, client, logger);
+                        return new StreamSystem(paramsWithEndPoint, client, logger);
                     }
                 }
                 catch (Exception e)

Original file line number	Diff line number	Diff line change
`@@ -66,12 +66,13 @@ public static async Task<StreamSystem> Create(StreamSystemConfig config, ILogger`
`66`	`66`	`{`
`67`	`67`	`try`
`68`	`68`	`{`
`69`		`- var client = await Client.Create(clientParams with { Endpoint = endPoint }, logger)`
	`69`	`+ var paramsWithEndPoint = clientParams with { Endpoint = endPoint };`
	`70`	`+ var client = await Client.Create(paramsWithEndPoint, logger)`
`70`	`71`	`.ConfigureAwait(false);`
`71`	`72`	`if (!client.IsClosed)`
`72`	`73`	`{`
`73`	`74`	`logger?.LogDebug("Client connected to {@EndPoint}", endPoint);`
`74`		`- return new StreamSystem(clientParams, client, logger);`
	`75`	`+ return new StreamSystem(paramsWithEndPoint, client, logger);`
`75`	`76`	`}`
`76`	`77`	`}`
`77`	`78`	`catch (Exception e)`