var queue_client = require('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.init(exchange_name, rabbitmq_connection)

var topic = 'user.created';
queue.publish(topic, {user_id: 4});

var queue_name = 'welcome_emails';
queue.subscribe(queue_name, {ordered: true}, {
  'user.created': function(payload, done) {
    var user_id = payload.user_id;
    // send welcome email to user_id
    done(true);
  }
});

var queue_name = 'apns_notifications';
queue.subscribe(queue_name, {delay: 2000}, {
  'user.created': function(payload, done) {
    var user_token = payload.user_token;
    // send apns notification to user_token
    done(true);
  }
});