@shankarregmi/common

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