<div class="gmail_quote"><div>Hi Alan,<br> <br></div><blockquote class="gmail_quote" style="margin:0pt 0pt 0pt 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex">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.<div>
<br></div><div>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<br>
<br></div></blockquote><div><br>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.<br> <br></div>
<blockquote class="gmail_quote" style="margin:0pt 0pt 0pt 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex"><div>Also check with the management plugin see if there is a message in the queue ready to be consumed.</div>
</blockquote><div><br>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?<br>
<br>Thanks,<br>Arun<br></div></div>