configuré un microservicio con nestjs y Redis y lo probé desde otro similar y funcionó, pero cuando quiero probarlo usando redis-cli de esta manera
PUBLISH add "message"o
PUBLISH update "message"No funciona, mi microservicio no recibe el mensaje y mi configuración en Nest
import { Controller } from '@nestjs/common'; import { MessagePattern, Payload } from '@nestjs/microservices'; import { WatchersService } from './watchers.service'; import { PostDto } from '../dto/post.dto'; @Controller() export class WatchersController { constructor(private readonly watchersService: WatchersService) {} @MessagePattern({ cmd: 'add' }) up(@Payload() data: PostDto) { return this.watchersService.up(data); } @MessagePattern({ cmd: 'update' }) down(@Payload() data: PostDto) { return this.watchersService.down(data); } }y así envío mensajes desde otro microservicio
import { Body, Controller, Inject, Post } from '@nestjs/common'; import { ClientProxy } from '@nestjs/microservices'; @Controller() export class AppController { constructor(@Inject('RANDOM_SERVICE') private client: ClientProxy) {} @Post('/add') deviceUp(@Body() data) { return this.client.send({ cmd: 'add' }, data); } @Post('/update') deviceDown(@Body() data) { return this.client.send({ cmd: 'update' }, data); } }