Does the RabbitMQ module support binding multiple routing keys to the same queue?

[amroczeK]

I am developing a software architecture using RabbitMQ as the message broker and want to use a Topic Exchange. Some services require multiple routing keys to be bound to the same queue.

Reference: https://www.rabbitmq.com/tutorials/tutorial-five-javascript.html

We created three bindings: Q1 is bound with binding key ".orange." and Q2 with "..rabbit" and "lazy.#".

These bindings can be summarised as:

Q1 is interested in all the orange animals.
Q2 wants to hear everything about rabbits, and everything about lazy animals.

I have already attempted to replicate this in the code example below. But whenever the order service publishes to the inventory queue with the routing key 'shop.order.created', it is received by the first RabbitSubscribe decorator configured..

The documentation talks about Competing Consumers for when you have two decorators using the same named queue. But why does this apply if the routingKey is different, this means that the exchange and queue aren't adhearing to the routing key.

In RabbitMq management, it shows that the inventory queue has two different routing keys bound. Is there a work around other than NOT using a named queue for the other routing key as this would create a new queue which I don't want and doesn't follow the desired pattern.

@RabbitSubscribe({
    exchange: 'shop.topic',
    routingKey: 'shop.inventory.*',
    queue: 'inventory',
  })
  async handleInventory(
    @RabbitPayload()
    inventoryData: any,
    @RabbitRequest() request: IRabbitRequest,
  ): Promise<void> {
    this.logger.log(`handleInventory()`);
    const routingKey = request.fields.routingKey;
    switch (routingKey) {
      case 'shop.inventory.update': {
        // TODO: Validate payload
        this.logger.log(`shop.inventory.update`);
        break;
        this.inventoryService.updateInventory(inventoryData);
        break;
      }
      default: {
        this.logger.log(
          `There is no handler for message with routing key: ${routingKey}`,
        );
        break;
      }
    }
  }

  @RabbitSubscribe({
    exchange: 'shop.topic',
    routingKey: 'shop.order.created',
    queue: 'inventory',
  })
  async test(
    @RabbitPayload()
    inventoryData: any,
    @RabbitRequest() request: IRabbitRequest,
  ): Promise<void> {
    this.logger.log(`test(): ${request.fields.routingKey}`);
  }