Handler cannot receive messages published in topic exchange in a microservice architecture

[kasir-barati]

Hey folks,

I am trying to send a message from driver microservice to audit-log in NestJS with @golevelup/nestjs-rabbitmq lib but unfortunately it does not work as it is working when I have everything in a monolithic NestJS app. You can reproduce it here: https://github.com/kasir-barati/rabbitmq-microservice-nestjs-bug

Read the README.md carefully and you'll understand my point. Fun fact, when I use a library like amqplib to consume messages published in audit_log.logs queue I can receive them 🥹, I tried to run this code right after I started my backend apps and it was logging the published message:

import { Channel, connect, Connection } from 'amqplib';
const connection = await connect('amqp://rabbitmq:password@localhost:5672');
const channel = await this.connection.createChannel();

channel.consume(
  'audit_log.logs',
  (message) => {
    console.log(`Message for "${AUDIT_LOG_QUEUE}"`);
    console.log(message?.content?.toString());
  },
  { noAck: false },
);

Another note is that when I activate Firehose Tracer it shows that messages are published and delivered to the right queue. My problem is that NestJS is not calling handlers that I've defined.

Any form of help is appreciated ❤️.

[kasir-barati]

Solved: #851