Example rabbitmq stuff

gistfile1.js

var queueService = require('module-tsl-rabbit/Queue');
var exchangeService = require('module-tsl-rabbit/Exchange');

var resourceHandler = {
  onMessage: function (data, message, ackFn, nackFn) {
    console.dir(data); // expect {hello:"world"}
    ackFn();
  }
}

async.series([
  exchangeService.connect('resourceTopic'),
  queueService.listen('resourceQueue', resourceHandler),
],function(err) {
  exchangeService.exchanges.resourceTopic.publish({hello:"world"});
});

/* ... elsewhere in the app config:

    "rabbitmq": {
        "resourceQueue": {
            "vhost": "resources",
            "exchange": "resources_data",
            "exchangeType": "topic",
            "queue": "resource_queue",
            "options": {
                "durable": true
            }
        },
        "resourceTopic": {
            "vhost": "resources",
            "exchange": "resources_data",
            "exchangeType": "topic",
            "options": {
                "durable": true
            }
        }
    }
    
*/