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)