[rabbitmq-discuss] QoS prefetch and rabbitmq-c
paul.pearcy at wallst.com
Thu Dec 16 22:10:31 GMT 2010
Don't see a direct way via rabbitmq-c to setup QoS prefetch count for a consumer. Searching the lists, I came across this thread, which seemed to have a sample for how to do this:
Is rolling your own QoS via amqp_simple_rpc the current recommended (only?) way to do this?
Here is the chunk of code I am referring to:
/* amqp.h should support this */
static int _amqp_basic_qos(amqp_connection_state_t state,
amqp_rpc_reply_t rpc_reply =
AMQP_SIMPLE_RPC(state, channel, BASIC, QOS, QOS_OK,
amqp_basic_qos_t, prefetch_size, prefetch_count, global);
if (rpc_reply.reply_type != AMQP_RESPONSE_NORMAL)
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the rabbitmq-discuss