1.1.6 • Published 1 year ago
@shankarregmi/common v1.1.6
Common Package For TypeScript
AMQP Client (rabbitMQ Wrapper)
initialize(optioins)
const rabbitMQClient = new AMQPClient({}); // Connect to rabbitMQ broker and creates a transmission channel rabbitMQClient.initialize();
registerRPCHandlers(handlers: {})
import { createUsers, getUsers } from "./userController"; rabbitMQClient.registerRPCHandlers({ createUsers, getUsers });
callRPC({})
rabbitMQClient.callRPC({ targetQueue: 'users', method: 'getUsers', params: { active: true, } });