VimUnDoi~#OT} PE bG"! "config": "~0.4.15",O8_O "version": "0.0.0",5_O "node": "*"5_O "node": "0.6 || 0.8"5_O{R "author": "Geoff Wagstaff (http://www.geoffwagstaff.com)", "name": "fuzz",' "description": "RabbitMQ controller", "version": "0.0.1", "repository": {0 "url": "http://github.com/thedeveloper/fuzz" }, "main": "lib/fuzz.js", "scripts": { "test": "test/fuzz.js" }, "dependencies": { "debug": "~0.7.0", "amqp": "~0.1.3", "config": "~0.4.15", "docker": "~0.1.1" }, "devDependencies": {}, "optionalDependencies": {}, "engines": { "node": "0.6 || 0.8" }}5_O X 5_ .v.O  5_ .v.O  5_  .v.O  "homepage": ""5_ 2 .v.O  2 "homepage": "http://www.geoffwagstaff.com/fuzz/"5_ 0v0OFF  "version": "0.0.1",5_ 0v0O68  "version": "0.0.2",5_  0v0O8 "docker": "~0.1.2"5_ 0v0O8 "devDependencies": {},5_0v0O85_0v0O8 5_0v0O8 "config": "~0.4.15",5_ 0v0O8 "docker": "~0.1.2"5_  0v0O8 "devDependencies": {},""var config = require('../config');var amqp = require('amqp');%var debug = require('debug')('fuzz');/var eventHandlers = require('./eventHandlers');'module.exports = fuzz = function(conf){ self = this; self.connection = null; self.config = conf || config; self.connected = false;/ self.eventHandlers = new eventHandlers(self);};/** * Establish an amqp connection.* * @param conf - amqp configuration objectH * @param cb - callback to fire when the amqp triggers the 'ready' event */&fuzz.prototype.connect = function(cb){ var self = this; if(self.connection){4 // If rabbit connection already exists, close ita self.connection.end(); // Will trigger the 'close' event, invoking the eventHandler for close }@ self.connection = amqp.createConnection(self.config.rabbitmq);U // Set up internal event handlers. Each handler function name matches an amqp event1 self.eventHandlers.wireEvents(self.connection);+ self.connection.once('ready', function(){ cb(null, self.connection); });, self.connection.once('error', function(e){ cb(e, null); });}5