queue.js

var amqp = require('amqp');

var connection = amqp.createConnection({});

connection.on('ready', function () {

  'use strict';

  connection.exchange('chat', {type: 'topic'}, function(exchange) {
    connection.queue( 'users', function (queue) {
      queue.bind(exchange, 'users.*', function(q) {
        q.subscribe(function (message, headers, deliveryInfo) {
          console.log(headers);
          console.log(deliveryInfo);
          console.log(JSON.stringify(message));
        });
      });
    });
  });
});