How can I unbind only one binding, not the whole queue?

[ma...@lindenlab.com]

In my app there is one direct exchange, each consumer has one exclusive queue, and then each queue has multiple bindings with the exchange.

I would like to unbind ONLY one binding, but the amqp documentation for unbind seems to not be able to do this.

    queue.bind(exchange, routing_key: 'id1')

    queue.bind(exchange, routing_key: 'id2')

    queue.unbind(exchange, routing_key: 'id2') #=> Unbind ONLY id2 (DO NOT WORKS)

But the unbind method does not have routing_key option, and will just remove all declared bindings in queue.

How could I unbind only one binding, not the whole queue?

Is there any other pattern I should be using? (for example, I could use multiple queues per consumer, but this looks very inefficient)

--

PD: This question is also in StackOverflow

[Michael Klishin]

2012/12/18 <ma...@lindenlab.com>

But the unbind method does not have routing_key option, and will just remove all declared bindings in queue.

This looks like an amq-protocol limitation that is easy to fix. I will look into it soon.

RabbitMQ HTTP API supports removing individual bindings, but it is one of a few operations not implemented in

the Ruby client [1] yet and identifying bindings is a little annoying.

1. https://github.com/ruby-amqp/rabbitmq_http_api_client

--
MK

http://github.com/michaelklishin
http://twitter.com/michaelklishin

[Michael Klishin]

2012/12/27 Michael Klishin <michael....@gmail.com>

This looks like an amq-protocol limitation that is easy to fix. I will look into it soon.

Actually, AMQP::Queue#unbind does support the :routing_key option:

https://github.com/ruby-amqp/amqp/blob/master/lib/amqp/queue.rb#L360

Can you please put together a small example that demonstrates the issue?

[Michael Klishin]

2012/12/27 Michael Klishin <michael....@gmail.com>

Actually, AMQP::Queue#unbind does support the :routing_key option:

https://github.com/ruby-amqp/amqp/blob/master/lib/amqp/queue.rb#L360

Can you please put together a small example that demonstrates the issue?

The following test demonstrates that unbinding from a direct exchange with a specific routing key does work:

https://github.com/ruby-amqp/amqp/commit/3ec080d1ce48db3f3ab13e41801128a27d020efa

and the [reference] documentation is now updated:

https://github.com/ruby-amqp/amqp/commit/02795c6828128871a94b74345d12f792cb19ac8a