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

Add support for amqplib #156

Merged
merged 7 commits into from
Sep 13, 2016
Merged

Add support for amqplib #156

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
5c4681d
feat (amqplib): integrate amqplib
phucpnt Sep 7, 2016
64ffe19
test (amqplib): add test case
phucpnt Sep 7, 2016
e31ec8d
fix (package.json): add amqplib as optional dependency
phucpnt Sep 7, 2016
bc6a2d0
fix (url): correct url for amqp broker
phucpnt Sep 8, 2016
01b837d
docs (README.md): add example config for usage with amqplib
phucpnt Sep 8, 2016
860b1a2
fix (store type declare): add amqplib as store type
phucpnt Sep 10, 2016
eb13909
chore (amqplib): remove console.log
phucpnt Sep 12, 2016
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
fix (url): correct url for amqp broker
  • Loading branch information
@phucpnt
phucpnt committed Sep 8, 2016
commit bc6a2d0f0825422ef111738ceaa335546c53f05a
6 changes: 3 additions & 3 deletions lib/amqplib_ascoltatore.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,11 +60,11 @@ AMQPLibAscoltatore.prototype._startConn = function () {

if (this._client_conn === undefined) {

var clientOpts = this._opts.client;
var url = ['amqp://' , clientOpts.login, ':', clientOpts.password, '@', clientOpts.host, ':', clientOpts.port].join('');
var url = this._opts.url || 'amqp://127.0.0.1:5672';

var socketOptions = this._opts.socketOptions || {};

debug("connecting to " + this._opts.client);
debug("connecting to " + this._opts.url);

steed.series([
function (callback) {
Expand Down