tungba103 / amqp

Node.js code for RabbitMQ tutorials

To successfully use the examples you will need a running RabbitMQ server.

Run rabbit MQ Server in localhost docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.12-management

Requirements

Node.js

You need Node.js and amqplib to run these tutorials.

Client Library

To install amqplib using npm:

npm install amqplib -g

Code

Tutorial one: "Hello World!":

node src/send.js
node src/receive.js

Tutorial two: Work Queues:

node src/new_task.js "A very hard task which takes two seconds.."
node src/worker.js

Tutorial three: Publish/Subscribe

node src/receive_logs.js
node src/emit_log.js "info: This is the log message"

Tutorial four: Routing:

node src/receive_logs_direct.js info
node src/emit_log_direct.js info "The message"

Tutorial five: Topics:

node src/receive_logs_topic.js "*.rabbit"
node src/emit_log_topic.js red.rabbit Hello

Tutorial six: RPC:

node src/rpc_server.js
node src/rpc_client.js 30