How to use the @golevelup/nestjs-rabbitmq.RabbitRPC function in @golevelup/nestjs-rabbitmq
To help you get started, we’ve selected a few @golevelup/nestjs-rabbitmq examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
golevelup / nestjs / integration / rabbitmq / src / rpc / rpc.service.ts View on Github 
@Injectable()
export class RpcService {
@RabbitRPC({
routingKey: 'rpc',
exchange: 'exchange1',
queue: 'rpc',
})
rpc(message: object) {
return {
echo: message,
};
}
@UseInterceptors(TransformInterceptor)
@RabbitRPC({
routingKey: 'intercepted-rpc',
exchange: 'exchange1',
queue: 'intercepted-rpc',
})
interceptedRpc(message: {}) {
return {
message: 42,
};
}
}import { RabbitRPC } from '@golevelup/nestjs-rabbitmq';
import { Injectable, UseInterceptors } from '@nestjs/common';
import { TransformInterceptor } from '../transform.interceptor';
@Injectable()
export class RpcService {
@RabbitRPC({
routingKey: 'rpc',
exchange: 'exchange1',
queue: 'rpc',
})
rpc(message: object) {
return {
echo: message,
};
}
@UseInterceptors(TransformInterceptor)
@RabbitRPC({
routingKey: 'intercepted-rpc',
exchange: 'exchange1',
queue: 'intercepted-rpc',
})@golevelup/nestjs-rabbitmq
Badass RabbitMQ addons for NestJS
