rpc-dispatcher v0.3.2

RPC Dispatcher

A simple RPC Dispatcher which implements RPC pattern over RabbitMQ. Allows to register subscribers and dispatch events across the microservices.

Usage

const { RPCClient, RPCServer } = require('rpc-dispatcher')

(async () => {
    const server = new RPCServer('amqp://localhost')
    const client = new RPCClient('amqp://localhost')

    server.register('hello', (user: string) => `Hello ${user}`);
    server.listen();

    console.log(await client.emit('hello', 'John'))
})().catch(e => console.log(e))

Api reference

async emit(event: string, ...args: any[]) => Promise<any>

Emit new event.

register (event: string, callback: (...args: any[]) => any) => void

Register new event callback

async listen() => Promise<void>

Start listen for new requests. Use this after register events.

Versioning

We use SemVer for versioning. For the versions available, see the tags on this repository.

Authors

• Dominik Szamburski - Initial work - FFx0q

See also the list of contributors who participated in this project.

License

This project is licensed under the MIT License - see the LICENSE.md file for details