消息模式 - RabbitMQ/NestJS

Question

我正在尝试集成到使用 NestJS 完成的项目中，这是一个简单的 api，您可以在其中发布带有名称（或模式）的消息并将其发送到已实现与名称匹配的处理程序的系统。

我正在构建的系统非常小，使用 NestJS 并没有多大意义。

我遇到的问题如下：

我正在创建一个简单的 api，用于触发将消息发布到队列中。 消费者在使用 NestJS 的系统上。

我不知道如何为该消息赋予该系统可识别的模式。 例如：

假设我想发布一条名为“CreateRecord”的消息，其中包含要从另一个系统处理的有效负载，该系统具有同名的处理程序和实现。

使用 amqplib 如何给消息命名或模式？

Answer 1

您可以在发布消息时在内容对象中提供模式。

publish(
  'my_exchange',
  'routing_key',
  { pattern: 'CreateRecord', data: 'Record' },
);