小编Mid*_*ido的帖子

消息模式 - RabbitMQ/NestJS

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

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

我遇到的问题如下:

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

我不知道如何为该消息提供该系统可识别的模式。例如:

假设我想发布一条名为“CreateRecord”的消息,其中的有效负载要从具有同名处理程序和实现的其他系统进行处理。

使用 amqplib 如何为消息指定名称或模式?

rabbitmq node-amqplib nestjs

3
推荐指数
1
解决办法
2632
查看次数

标签 统计

nestjs ×1

node-amqplib ×1

rabbitmq ×1