rabbitmq - NestJS 微服务与 rabbitmq 没有模式

Question

我有一个 rabbitmq 服务，它有一个队列，消息中没有模式 json。

像这样：

{"customFieldOne": "foo", "another": "bar", "numbers": [3, 5, 8]}

但是带有 rabbitmq 的 nestjs 需要一个 json 模式，如下所示：

{"pattern": "my-pattern", "data": {"fieldOne": 1 ...}}

它必须具有模式和数据字段。

有没有办法在没有定义模式或模式的情况下使用任何 json 消息？

在我的代码中，我使用了模式，但我需要使用来自 rabbitmq 的任何数据和 nestjs 微服务。

@MessagePattern('my-pattern')
// @EventPattern('my-pattern')
getNotifications(@Payload() data: number[], @Ctx() context: RmqContext) {
  console.log(data);
  console.log(`Pattern: ${context.getPattern()}`);
}

我怎样才能做到这一点？

标签： rabbitmqnestjs