[rabbitmq-discuss] rabbitmq-c: Nonblocking recv

Arun Chandrasekaran visionofarun at gmail.com
Fri Feb 17 06:06:55 GMT 2012


Hi Alan,


> Brief glance at the code - it looks good to me, except for the FD_SET(...)
> line which seems to have an extra ) after the sock variable.
>
> I would uncomment the line you have commented. Its likely that if you run
> this program after amqp_producer.c program, that a frame or two is cached
> and that the result of amqp_frames_enqueued() is returning true
>
>
Thanks, I've done that. But I may be missing something here. So I've
attached the hg diff to make sure the changes are in the right place for
the non-blocking consumer.


> Also check with the management plugin see if there is a message in the
> queue ready to be consumed.
>

Currently I run on RHEL5. So I'll have to install the latest Erlang, I'll
do that today. Alternatively I have made sure that the message is ready to
be consumed by starting the consumer ahead of the producer. Will that
suffice?

Thanks,
Arun
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120217/1d32ddec/attachment.htm>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: non-block-consume.diff
Type: application/octet-stream
Size: 1795 bytes
Desc: not available
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120217/1d32ddec/attachment.obj>


More information about the rabbitmq-discuss mailing list