Initializing Rabbit Module creates random queues

[shreyassood]

On initializing a module with a queue specified, the library creates random queues if createQueueIfNotExists is on.

This happens at

nestjs/packages/rabbitmq/src/amqp/connection.ts

Lines 304 to 305 in be88a40

	await channel.assertQueue(configuredQueue.name, configuredQueue.options);

within the setupQueuesWithBindings method.

The setupQueue method expects a subscriptionsOptions object of type MessageHandlerOptions but is passed in an object of type RabbitMQQueueConfig. This object does not have the queue property

nestjs/packages/rabbitmq/src/amqp/connection.ts

Lines 671 to 672 in be88a40

	queue: queueName = '',
	} = subscriptionOptions;

and causes Rabbit to initialize a queue with a [random name] (https://www.rabbitmq.com/queues.html#server-named-queues).

Also on a side note: should assertQueue not create a queue at

nestjs/packages/rabbitmq/src/amqp/connection.ts

Lines 304 to 305 in be88a40

	await channel.assertQueue(configuredQueue.name, configuredQueue.options);

regardless anyway (createQueueIfNotExists) in this case shouldn't matter?

[liudichen]

I also encountered this issue, and it's not just the queue attribute, but also the queueOptions attribute with different names in the two configurations

maybe should modify this line:

nestjs/packages/rabbitmq/src/amqp/connection.ts

Line 302 in be88a40

this.setupQueue(configuredQueue, channel);

to

this.setupQueue({...configuredQueue,queue: configuredQueue.name,queueOptions:configuredQueue.options}, channel)

[underfisk]

The next version shall include the fix for this, bumping here for @WonderPanda

[huantaoliu]

nice

[shreyassood]

Awesome, thanks for working on this!

[underfisk]

Awesome, thanks for working on this!

All the merit goes to @ttshivers ! He's doing an amazing job helping out

[trickaugusto]

Hello everyone!

I had the same problem, but I used version 5.0.0 and it didn't solve the problem...
Has this gone to production?