I have the following dynamic module that accepts an enum of topics:
I then import it in the root module of one of my services:
This results in the following acknowledgement being logged when I run my service (4th line from bottom): 'Successfully connected a RabbitMQ channel "AmqpConnection'.
Also please note the presence of EmailVerificationService in the providers array.
The issue is that despite EmailVerificationService being included in the providers array of the same module where I imported AppRabbitMQModule, and it having a method 'sendEmailVerification' which is decorated with RabbitSubscribe, the queue subscriber is not being registered. I already tried tried making the method public instead of protected, making it protected is just a habit that I have
I've checked my RabbitMQ instance directly via the management console and the topics are being successfully created but the queues are not, and the amqpConnection is being successfully provided as I have a module that would fail otherwise.
I have the following dynamic module that accepts an enum of topics:
I then import it in the root module of one of my services:
This results in the following acknowledgement being logged when I run my service (4th line from bottom): 'Successfully connected a RabbitMQ channel "AmqpConnection'. Also please note the presence of EmailVerificationService in the providers array.
The issue is that despite EmailVerificationService being included in the providers array of the same module where I imported AppRabbitMQModule, and it having a method 'sendEmailVerification' which is decorated with RabbitSubscribe, the queue subscriber is not being registered. I already tried tried making the method public instead of protected, making it protected is just a habit that I have
I've checked my RabbitMQ instance directly via the management console and the topics are being successfully created but the queues are not, and the amqpConnection is being successfully provided as I have a module that would fail otherwise.
Any ideas on what could be causing the issue?