diff --git a/lib/amqplib_ascoltatore.js b/lib/amqplib_ascoltatore.js index 855596e..fd81a02 100644 --- a/lib/amqplib_ascoltatore.js +++ b/lib/amqplib_ascoltatore.js @@ -93,7 +93,7 @@ AMQPLibAscoltatore.prototype._startConn = function () { function(callback){ debug('channel created'); that._queue = that._opts.queue || util.buildIdentifier(); - that._channel.assertQueue(that._queue, {durable: (that._opts.durableQueue !== false)}, wrap(callback)); + that._channel.assertQueue(that._queue, {durable: !!that._opts.durableQueue}, wrap(callback)); }, function (callback){