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 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.