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
Minor change
  • Loading branch information
@shadyvd
shadyvd committed Feb 13, 2018
commit 2000da39748fad2dd7cce6777d0f3394a0d30eed
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 @@ -145,7 +145,7 @@ AMQPLibAscoltatore.prototype.subscribe = function subscribe(topic, callback, don
AMQPLibAscoltatore.prototype.publish = function publish(topic, message, done) {
this._raiseIfClosed();

debug("new message published to " + topic);
debug("new message published to " + this._pubTopic(topic));

this._channel.publish(this._opts.exchange, this._pubTopic(topic), new Buffer(String(message)));
defer(done);
Expand Down