From 748cc9d93c745a4a1fd9068c08e9dd09bd5291c1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Troels=20M=C3=B8ller=20Larsen?= <troels@mlarsen.com>
Date: Mon, 25 Sep 2023 23:02:22 +0200
Subject: [PATCH] Fixing Endpoint passed to StreamSystem

---
 RabbitMQ.Stream.Client/StreamSystem.cs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/RabbitMQ.Stream.Client/StreamSystem.cs b/RabbitMQ.Stream.Client/StreamSystem.cs
index daa5c419..76811a50 100644
--- 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)