Comparing version 0.1.11 to 0.1.12
@@ -13,11 +13,8 @@ 'use strict'; | ||
var defaults = { | ||
middleware: [], | ||
amqpUrl: 'amqp://guest:guest@localhost:5672', | ||
url: 'amqp://guest:guest@localhost:5672', | ||
exchange: 'amq.topic', | ||
exchangeType: 'topic', | ||
queue: 'amqper', // todo routeToQueueName(route) | ||
queueOpts: {durable: true, autoDelete: false, messageTtl: 30000, expires: 3600000}, | ||
autoAck: false, | ||
errorHandler: function (err) { | ||
console.error(err); | ||
} | ||
autoAck: false | ||
}; | ||
@@ -81,3 +78,3 @@ | ||
return when.all([ | ||
ch.assertExchange(that.options.exchange, 'topic'), | ||
ch.assertExchange(that.options.exchange, that.options.exchangeType), | ||
ch.assertQueue(that.options.queue, that.options.queueOpts), | ||
@@ -84,0 +81,0 @@ ch.bindQueue(that.options.queue, that.options.exchange, routingKey), |
{ | ||
"name": "amqper", | ||
"version": "0.1.11", | ||
"version": "0.1.12", | ||
"description": "A simple and elegant AMQP client for node based on amqplib.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/taoyuan/amqper", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
19581
496