RMQ-RX
This library helps you send and receive messages throw RabbitMQ RX way. You can use it with JavaScript or TypeScript. Code below shows its usage with TypeScript. To connect to RMQ just import connector and call connect():
;;await rmqConnector.connect;
Where 'logger' is queue name and connection string is a string with amqp credentials:
`amqp://:@`
Server
One app (lets call it server) is listening to queue, recive messages and replies:
rmqConnector.listen.subscribe;
listen() - listens to queue and gets messages with interface
action - an action that your server can execute. It is good to use it as emun. data - any data that you can describe with the interface when sending it. replyTo - queue to reply. It will be generated automatically.
reply() - replies to a client with status 'ok' or 'error' and description message.
Client
To post your action call post() function:
rmqConnector.postPostType.saveLog,.subscribe;
SaveLog - interface which you can describe in your contract. For example:
PostType.saveLog - action we discussed earlier. reply - a reply that server sent with interface:
If you want to disconnect from 'queue' just call:
rmqConnector.disconnect;