diff --git a/lib/sockets.js b/lib/sockets.js index 27f13ec..6f98b69 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -193,11 +193,12 @@ PubSocket.prototype.connect = function(destination, callback) { }; } -PubSocket.prototype.publish = function(topic, chunk, encoding) { +PubSocket.prototype.publish = function(topic, chunk, encoding, opt = {}) { var ch = this.ch; if (!topic) topic = this.options.topic || ''; var options = {expiration: this.options.expiration, - persistent: this.options.persistent}; + persistent: this.options.persistent, + ...opt}; var allpubs = true; this.pubs.forEach(function(dest) { allpubs = allpubs && diff --git a/package.json b/package.json index da687c9..052bfe4 100644 --- a/package.json +++ b/package.json @@ -1,13 +1,12 @@ { - "name": "rabbit.js", - "description": "Easy stream-based messaging using RabbitMQ", - "version": "0.4.4", - "homepage": "http://github.com/squaremo/rabbit.js", + "name": "rabbit.js-fix", + "description": "fork from https://github.com/squaremo/rabbit.js : Easy stream-based messaging using RabbitMQ", + "version": "0.4.5", + "homepage": "https://github.com/jimliu7434/rabbit.js", "repository": { "type": "git", - "url": "https://github.com/squaremo/rabbit.js.git" + "url": "https://github.com/jimliu7434/rabbit.js" }, - "author": "Michael Bridgen ", "directories": { "lib": "lib", "test": "test" @@ -17,7 +16,7 @@ "test": "./node_modules/mocha/bin/mocha --ui exports test" }, "engines": { - "node": ">=0.8 <0.13 || ^1" + "node": ">=8.0" }, "dependencies": { "amqplib": "0.3.2",