diff --git a/src/lib/connect/index.ts b/src/lib/connect/index.ts
index a25863f78..ef8bef0ed 100644
--- a/src/lib/connect/index.ts
+++ b/src/lib/connect/index.ts
@@ -72,17 +72,17 @@ function connect(
 		parsedOptions.protocol = parsedUrl.protocol as MqttProtocol
 		parsedOptions.path = parsedUrl.path
 
-		parsedOptions.protocol = parsedOptions.protocol?.replace(
-			/:$/,
-			'',
-		) as MqttProtocol
-
 		opts = { ...parsedOptions, ...opts }
 
 		// when parsing an url expect the protocol to be set
 		if (!opts.protocol) {
 			throw new Error('Missing protocol')
 		}
+
+    opts.protocol = opts.protocol.replace(
+      /:$/,
+      '',
+    ) as MqttProtocol
 	}
 
 	opts.unixSocket = opts.unixSocket || opts.protocol?.includes('+unix')