RabbitMQ Node.js simple client
This Node.js client for RabbitMQ provides simple PUB/SUB features.
Initialization of the client
var queue_client = ;var exchange_name = 'exchange-to-use';var rabbitmq_connection = host: 'localhost' port: 5672 login: 'guest' password: 'guest' authMechanism: 'AMQPLAIN' vhost: '/' ssl: enabled: false ; queue = queue_client
The rabbitmq_connection
is sent to the createConnection
method of the amqp library. Check its documentation to see the available options/defaults.
Example of use to publish messages:
var topic = 'user.created';queue;
Example of use to subscribe to messages:
var queue_name = 'welcome_emails';queue;
Delayed Queues
To create a delayed queue, specify the delay in milliseconds in the subscription options:
var queue_name = 'apns_notifications';queue;
Note that order is NOT guaranteed across different routing keys in delayed queues.