Sample for node-amqp Event-driven Architecture

node-amqp-event-driven-arch-sample.js

// This code is just conceptual to illustrate the proposed future change.

var amqp = require('amqp'),
    connection = amqp.createConnection({ host: 'dev.rabbitmq.com' });

connection.on('ready', function () {
  function onMyQueueMessageReceived(message) {
    console.log(message);
  }

  function onMyQueueDeclared(q, feedback) {
    // feedback has the name of the queue (feedback.queueName), feedback.messageCount and feedback.consumerCount

    // Catch all messages
    q.bind('#');

    // Receive messages
    q.subscribe();
  }

  // Add listeners
  connection.on('queue.my-queue.declared', onMyQueueDeclared);
  connection.on('queue.my-queue.message_received', onMyQueueMessageReceived);

  // Declare "my-queue" queue.
  connection.declare_queue('my-queue');
});