diff --git a/packages/rabbitmq/src/amqp/utils.ts b/packages/rabbitmq/src/amqp/utils.ts index 366b093c6..b3301095c 100644 --- a/packages/rabbitmq/src/amqp/utils.ts +++ b/packages/rabbitmq/src/amqp/utils.ts @@ -29,7 +29,7 @@ export function matchesRoutingKey( } const rabbitMQRegex = - /^amqp:\/\/(([^:]+):([^@]+)@)?([^:/]+)(:[0-9]+)?(\/[^\/]+)?$/; + /^amqps?:\/\/(([^:]+):([^@]+)@)?([^:/]+)(:[0-9]+)?(\/[^\/]*)?$/; /** * Validates a rabbitmq uri diff --git a/packages/rabbitmq/src/tests/rabbitmq.utils.spec.ts b/packages/rabbitmq/src/tests/rabbitmq.utils.spec.ts index 590b4aa92..4bf17e7de 100644 --- a/packages/rabbitmq/src/tests/rabbitmq.utils.spec.ts +++ b/packages/rabbitmq/src/tests/rabbitmq.utils.spec.ts @@ -69,6 +69,9 @@ describe(matchesRoutingKey.name, () => { assertRabbitMqUri([ 'amqp://rabbitmq:rabbitmq@localhost:4444', 'amqp://rabbitmq:rabbitmq@localhost:1234', + 'amqps://rabbitmq:rabbitmq@localhost:2345', + 'amqp://rabbitmq:rabbitmq@localhost:3456/', + 'amqps://rabbitmq:rabbitmq@localhost:4567/', ]), ).not.toThrowError(); });