diff --git a/lib/sockets.js b/lib/sockets.js index 27f13ec..f0997fc 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -2,7 +2,7 @@ var amqp = require('amqplib'); var inherits = require('util').inherits; var EventEmitter = require('events').EventEmitter; var Stream = require('stream'); -var guid = require('node-uuid').v4; +var guid = require('uuid/v4'); var Readable = Stream.Readable || require('readable-stream/readable'); var Writable = Stream.Writable || require('readable-stream/writable'); @@ -43,7 +43,7 @@ function Context(url, connOpts) { ['close', 'blocked', 'unblocked'].forEach(function(ev) { conn.on(ev, self.emit.bind(self, ev)); }); - }); + }).catch( onError ); c.then(this.emit.bind(this, 'ready')).then(null, onError); }; inherits(Context, EventEmitter); diff --git a/package.json b/package.json index da687c9..2586073 100644 --- a/package.json +++ b/package.json @@ -1,7 +1,7 @@ { - "name": "rabbit.js", + "name": "rabbit.js.ng", "description": "Easy stream-based messaging using RabbitMQ", - "version": "0.4.4", + "version": "0.5.1", "homepage": "http://github.com/squaremo/rabbit.js", "repository": { "type": "git", @@ -20,11 +20,11 @@ "node": ">=0.8 <0.13 || ^1" }, "dependencies": { - "amqplib": "0.3.2", - "node-uuid": "", - "readable-stream": "~1 >=1.0.2" + "amqplib": "0.5.3", + "readable-stream": "3.0.6", + "uuid": "^3.3.2" }, "devDependencies": { - "mocha": "" + "mocha": "^5.2.0" } }