You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have a piece of software that uses queue.bind() to bind a queue to an exchange with a random name. When I receive a message from that queue, I want to unbind the queue from the exchange. For that purpose the message contains the exchange name, which I use with queue.unbind(). This works great.
The problem arises when my software is restarted after the bind but before the unbind because then queue.unbind() blows up in my face. Source code of this function shows that there is no guard against this._bindings[exchangeName] being undefined.
I have a fix and will post a PR. In the meantime, a workaround is to make the exchange known by calling connection.exchange() before calling queue.unbind().
I'm using amqp-0.2.6 and node-6.9.1.
The text was updated successfully, but these errors were encountered:
gisode
pushed a commit
to gisode/node-amqp
that referenced
this issue
Jan 19, 2017
I have a piece of software that uses
queue.bind()
to bind a queue to an exchange with a random name. When I receive a message from that queue, I want to unbind the queue from the exchange. For that purpose the message contains the exchange name, which I use withqueue.unbind()
. This works great.The problem arises when my software is restarted after the bind but before the unbind because then
queue.unbind()
blows up in my face. Source code of this function shows that there is no guard againstthis._bindings[exchangeName]
beingundefined
.I have a fix and will post a PR. In the meantime, a workaround is to make the exchange known by calling
connection.exchange()
before callingqueue.unbind()
.I'm using amqp-0.2.6 and node-6.9.1.
The text was updated successfully, but these errors were encountered: