nestjs-amqp

import { Injectable } from '@nestjs/common';
import { BrokerAction, BrokerParam } from '@open-rlb/nestjs-amqp';

@Injectable()
export class OrdersService {
  // (topic, action) = ('orders', 'order.create') — unique across the app
  @BrokerAction('orders', 'order.create', 'rpc')
  create(
    @BrokerParam('header', 'X-GTW-AUTH-USERID') userId: string, // one header
    @BrokerParam('body', 'sku') sku: string,                    // one body field
    @BrokerParam('body-full') payload: any,                     // whole body
    @BrokerParam('action') action: string,                      // the action string
  ) {
    return { ok: true, userId, sku, action };
  }
}