Skip to content
This repository has been archived by the owner on Mar 10, 2020. It is now read-only.

AMQPLib: Allow queue and durability to be part of the configuration #182

Merged
merged 7 commits into from
Feb 15, 2018
Merged

AMQPLib: Allow queue and durability to be part of the configuration #182

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
08bb169
Allow queue name to be specified in AMQPLib configuration
shadyvd Feb 13, 2018
abd03f3
Minor change
shadyvd Feb 13, 2018
2000da3
Minor change
shadyvd Feb 13, 2018
7331b9e
Update README.md
shadyvd Feb 14, 2018
c1d6f9c
Update amqplib_ascoltatore.js
shadyvd Feb 14, 2018
e6f696a
Updated path to Kafka
shadyvd Feb 14, 2018
91a6bd4
Added options for conditional queue delete
shadyvd Feb 15, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update amqplib_ascoltatore.js
  • Loading branch information
@shadyvd
shadyvd authored Feb 14, 2018
commit c1d6f9c376040c616866cfceb13913a76bb0301d
2 changes: 1 addition & 1 deletion lib/amqplib_ascoltatore.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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){
Expand Down