examples

Examples

To run the examples, please start RabbitMQ server with docker compose up -d in the package root.

RPC

Run in two terminals:

$ node examples/rpc/producer

source

$ node examples/rpc/consumer

source

Events

Run in multiple terminals:

$ node examples/events/consumer A

$ node examples/events/consumer B

source

$ node examples/events/producer

source

A and B are consumer groups.

Try to run multiple instances with the same consumer group.

Reply streams

Run in two terminals:

$ node examples/streams/producer

source

$ node examples/streams/consumer

source