Need to add support for RPC Client and Server
Usage could look like this:
Client:
const result = await menash.rpc('server-queue-name', { info: "some request" });
Server:
await menash.activateRpcServer('server-queue-name', (msg: ConsumerMessage) => { msg.reply({ info: "my reply" }); })
Need to add support for RPC Client and Server
Usage could look like this:
Client:
const result = await menash.rpc('server-queue-name', { info: "some request" });Server:
await menash.activateRpcServer('server-queue-name', (msg: ConsumerMessage) => { msg.reply({ info: "my reply" }); })