[rabbitmq-discuss] rabbitmq-c Memory-Based Flow Control API.

Sun Jan 12 00:53:18 GMT 2014

Rohit;

On Thu, Jan 9, 2014 at 2:25 AM, Rohit Patle
<Rohit.Patel2 at techmahindra.com>wrote:

>  Hi Alan,
>
> Thanks you for your advise. But I am facing following issues with your
> suggestions as:
>
> 1. After doing #rabbitmqctl list_channels client_flow_blocked, I could see
> the "false" value is default set there. While using amqp_login(), I am
> unable to find  the "capabilities table" to set 'connection.blocked'=true
> as mentioned. Please let me know how to do it.
>

You pass in an amqp_table_t with an entry with the key 'capabilites' and
type table, that table should contain an entry with a key name
'connection.blocked', type boolean, and value of 1.  SimpleAmqpClient has
some code that does something similar with consumer notifications:
https://github.com/alanxz/SimpleAmqpClient/blob/2847a8cacd6499c9973b99e0b7b3694c36e90f79/src/ChannelImpl.cpp#L71

> 2.  While using amqp_simple_wait_frame_noblock() I am unable to find the
> enum values you mentioned(AMQP_CONNECTION_BLOCKED_METHOD and
> AMQP_CONNECTION_UNBLOCKED_METHOD) which I supposed to get as result of amqp_simple_wait_frame_noblock()
> in amqp.h or amqp_framing.h. Please suggest.
>

The connection.blocked method is fairly new and has only just recently
added to the master branch (there are no tagged releases with
connection.blocked support in it yet). The documentation you're looking has
not caught up. Those values will be in amqp_framing.h (see:
https://github.com/alanxz/rabbitmq-c/blob/master/librabbitmq/amqp_framing.h#L186)

-Alan
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140111/a79687f2/attachment.html>