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

Alan Antonuk alan.antonuk at gmail.com
Mon Jan 13 18:55:25 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
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140113/8228839a/attachment.html>


More information about the rabbitmq-discuss mailing list