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, } });
-