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

Feature/bn forward callback function #185

Open
wants to merge 5 commits into
base: master
Choose a base branch
from

Conversation

BlueBeN82
Copy link

No description provided.

Bernd Niehues and others added 5 commits February 21, 2018 10:36
When publishing a message to rabbitmq via amqp the options object was
dropped in amqp_ascolatore. The options object is now forwarded to
the exchange.
…change

[BUGFIX] Forward amqp options when publish to exchange
Adding exchangeOptions object (next to exchange in configuration) that
enables the user to declare the exchange as durable.
When publishing a message to rabbitmq via amqp the callback function was
defered independent of the result of exchange publish process.
Now the callback is called by this, enhancing reliability of "done"
state.
@@ -8,6 +8,12 @@ var AbstractAscoltatore = require('./abstract_ascoltatore');
var steed = require("steed")();
var SubsCounter = require("./subs_counter");
var debug = require("debug")("ascoltatori:amqp");
var _ = require('lodash');
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

can you please avoid adding lodash as a dependency?

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants