@OnRedisMessage('decoratorTest', (msg) => {returnmsg.data >10; // This middleware will act as filter,// only messagea with data greater than 10 will continue to the next method }) public static channelListener(data) {this.decoratorTestChannel = data }
@OnRedisPMessage('decoratorTestPattern-*',null, (msg:PubSubMessage<number>) => {returnmsg.data >10; // This middleware will act as filter,// only messagea with data greater than 10 will continue to the next method})public static patternListener(msg) {this.decoratorTestPattern = msg;}