diff --git a/packages/queue/src/connection.ts b/packages/queue/src/connection.ts index 60a50b38..d3d65c0d 100644 --- a/packages/queue/src/connection.ts +++ b/packages/queue/src/connection.ts @@ -1,9 +1,12 @@ const parse = (connectionString: string) => { - const url = new URL(connectionString); + const match = connectionString.match(/redis:\/\/(.+?):(.+?)@(.+?):(.+)/); + if (!match) { + throw new Error('Invalid connection string'); + } return { - host: url.hostname, - port: Number(url.port), - password: url.password, + host: match[3]!, + port: Number(match[4]), + password: match[2]!, } as const; };