<div dir="ltr">Initial support has been added in rabbitmq-c here:<div><a href="https://github.com/alanxz/rabbitmq-c/pull/133">https://github.com/alanxz/rabbitmq-c/pull/133</a><br></div></div><div class="gmail_extra"><br><br>
<div class="gmail_quote">On Wed, Aug 7, 2013 at 4:47 AM, Michael Klishin <span dir="ltr"><<a href="mailto:mklishin@gopivotal.com" target="_blank">mklishin@gopivotal.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
I'm happy to report that RabbitMQ 3.2 will support a new AMQP 0-9-1<br>
extension that makes it possible for clients to be notified about<br>
blocked connections [1].<br>
<br>
Documentation for the extension is available on <a href="http://next.rabbitmq.com" target="_blank">next.rabbitmq.com</a> [2].<br>
It is currently supported by 4 clients (in their development branches):<br>
<br>
* Java client<br>
* .NET client<br>
* Erlang client<br>
* Bunny (<a href="http://rubybunny.info" target="_blank">http://rubybunny.info</a>)<br>
<br>
with a couple more clients working on supporting it in the near future.<br>
<br>
If you maintain a RabbitMQ client, below are some notes about how<br>
you can add support for this extension.<br>
<br>
We've introduced two new AMQP 0-9-1 methods: connection.blocked<br>
and connection.unblocked. This codegen commit demonstrates what<br>
properties of what types they have:<br>
<a href="http://hg.rabbitmq.com/rabbitmq-codegen/rev/1748e6cf399a" target="_blank">http://hg.rabbitmq.com/rabbitmq-codegen/rev/1748e6cf399a</a><br>
<br>
Next, you need to add connection.blocked to the list of supported extensions<br>
in client capabilities.<br>
<br>
How these methods are exposed in the API is client-specific.<br>
3 clients (Java, .NET, Bunny) let users register event handlers (callbacks)<br>
on connection instances.<br>
<br>
Below are two diffs that may help you add support for connection.blocked<br>
to your client:<br>
<br>
<a href="http://hg.rabbitmq.com/rabbitmq-java-client/rev/fc3a59ca0aab" target="_blank">http://hg.rabbitmq.com/rabbitmq-java-client/rev/fc3a59ca0aab</a><br>
<a href="https://github.com/ruby-amqp/bunny/commit/334d0ceb3f84c03be342ad06dd244f0aa25fb7bc" target="_blank">https://github.com/ruby-amqp/bunny/commit/334d0ceb3f84c03be342ad06dd244f0aa25fb7bc</a><br>
<br>
To test this functionality you can either build RabbitMQ from source (on the default branch)<br>
or use nightly builds available from <a href="https://www.rabbitmq.com/nightly-builds.html" target="_blank">https://www.rabbitmq.com/nightly-builds.html</a><br>
<br>
If you have any questions about this extension, simply reply to this thread.<br>
<br>
1. <a href="http://www.rabbitmq.com/memory.html" target="_blank">http://www.rabbitmq.com/memory.html</a><br>
2. <a href="http://next.rabbitmq.com/connection-blocked.html" target="_blank">http://next.rabbitmq.com/connection-blocked.html</a><br>
--<br>
MK<br>
<br>
<br>_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></blockquote></div><br></div>