<div dir="ltr">Here is what it says:<div><br></div><div><div class="" style="font-weight:bold;font-size:14px;line-height:19px;font-family:Roboto,sans-serif;border-top-width:1px;border-top-style:solid;border-top-color:rgb(168,184,217);border-left-width:1px;border-left-style:solid;border-left-color:rgb(168,184,217);border-right-width:1px;border-right-style:solid;border-right-color:rgb(168,184,217);padding:6px 0px;color:rgb(37,53,85);background-image:url(http://alanxz.github.io/rabbitmq-c/docs/0.2/nav_f.png);background-color:rgb(226,232,242);border-top-right-radius:4px;border-top-left-radius:4px;background-repeat:repeat no-repeat">
<table class="" style="margin-left:6px"><tbody><tr><td class="" style="margin-left:6px;vertical-align:bottom"><a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/structamqp__basic__consume__ok__t.html" style="color:rgb(70,101,162)">amqp_basic_consume_ok_t</a>* amqp_basic_consume</td>
<td style="vertical-align:bottom">(</td><td class="" style="white-space:nowrap;vertical-align:bottom"><a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/amqp_8h.html#a59cfdff3bfbf28aba201be5636365fa4" style="color:rgb(70,101,162)">amqp_connection_state_t</a>�</td>
<td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">state,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom">
<a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/amqp_8h.html#a2905d3cff4f5b3e0a300c3d424181518" style="color:rgb(70,101,162)">amqp_channel_t</a>�</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">
channel,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom"><a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/structamqp__bytes__t.html" style="color:rgb(70,101,162)">amqp_bytes_t</a>�</td>
<td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">queue,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom">
<a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/structamqp__bytes__t.html" style="color:rgb(70,101,162)">amqp_bytes_t</a>�</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">
consumer_tag,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom"><a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/amqp_8h.html#a67852bce88f5784b60b8f873fd4673f2" style="color:rgb(70,101,162)">amqp_boolean_t</a>�</td>
<td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">no_local,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom">
<a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/amqp_8h.html#a67852bce88f5784b60b8f873fd4673f2" style="color:rgb(70,101,162)">amqp_boolean_t</a>�</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">
no_ack,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom"><a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/amqp_8h.html#a67852bce88f5784b60b8f873fd4673f2" style="color:rgb(70,101,162)">amqp_boolean_t</a>�</td>
<td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">exclusive,</td></tr><tr><td class="" style="text-align:right;vertical-align:bottom"></td><td style="vertical-align:bottom"></td><td class="" style="white-space:nowrap;vertical-align:bottom">
<a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/structamqp__table__t.html" style="color:rgb(70,101,162)">amqp_table_t</a>�</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;vertical-align:bottom">
arguments�</td></tr><tr><td style="vertical-align:bottom"></td><td style="vertical-align:bottom">)</td><td style="vertical-align:bottom"></td><td style="vertical-align:bottom"></td></tr></tbody></table></div><div class="" style="font-size:14px;line-height:19px;font-family:Roboto,sans-serif;border-width:0px 1px 1px;border-bottom-style:solid;border-bottom-color:rgb(168,184,217);border-left-style:solid;border-left-color:rgb(168,184,217);border-right-style:solid;border-right-color:rgb(168,184,217);padding:6px 10px 2px;background-image:url(http://alanxz.github.io/rabbitmq-c/docs/0.2/nav_g.png);border-bottom-left-radius:4px;border-bottom-right-radius:4px;color:rgb(0,0,0);background-repeat:repeat no-repeat">
<p>amqp_basic_consume</p><dl class="" style="padding:0px;margin-left:0px"><dt style="font-weight:bold">Parameters</dt><dd><table class="" style="margin-left:0px;padding-left:0px"><tbody><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">state</td><td>connection state</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">channel</td><td>the channel to do the RPC on</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">queue</td><td>queue</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">consumer_tag</td><td>consumer_tag</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">no_local</td><td>no_local</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">no_ack</td><td>no_ack</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">exclusive</td><td>exclusive</td></tr><tr><td class="" style="font-family:'courier new',courier,monospace;vertical-align:top">
[in]</td><td class="" style="color:rgb(96,32,32);white-space:nowrap;font-weight:bold;vertical-align:top">arguments</td><td>arguments</td></tr></tbody></table></dd></dl><dl class="" style="padding:0px;margin-left:0px"><dt style="font-weight:bold">
Returns</dt><dd style="margin-bottom:6px"><a class="" href="http://alanxz.github.io/rabbitmq-c/docs/0.2/structamqp__basic__consume__ok__t.html" title="basic.consume-ok method fields" style="color:rgb(70,101,162);font-weight:bold">amqp_basic_consume_ok_t</a></dd>
</dl></div></div></div><div class="gmail_extra"><br><br><div class="gmail_quote">On Mon, Dec 16, 2013 at 10:58 PM, Raj Kumar Sanpui <span dir="ltr"><<a href="mailto:raj.kumar.sanpui@gmail.com" target="_blank">raj.kumar.sanpui@gmail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div dir="ltr">Yeah, i will look at that right now, perhaps i was looking at my debug, and i found:<div>After i call:</div>
<div>amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);<br></div>
<div><br></div><div>Right after this call, the messages are truncated to 0.</div><div><br></div><div>I had put debug of queue count, before and after this.</div><div>Any hints?</div><div><br></div><div><br></div></div><div class="gmail_extra">
<br><br><div class="gmail_quote"><div><div class="h5">On Mon, Dec 16, 2013 at 10:45 PM, Michael Klishin <span dir="ltr"><<a href="mailto:michael.s.klishin@gmail.com" target="_blank">michael.s.klishin@gmail.com</a>></span> wrote:<br>
</div></div><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div><div class="h5">
<div dir="ltr"><div class="gmail_extra"><div><br><div class="gmail_quote">2013/12/16 Raj Kumar Sanpui <span dir="ltr"><<a href="mailto:raj.kumar.sanpui@gmail.com" target="_blank">raj.kumar.sanpui@gmail.com</a>></span><br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Yes, the messages are dispatched, but something happens in consume method, which makes it drop. I am trying a line-by-line debug.</blockquote>
</div><br></div>Have you tried looking at RabbitMQ log first? Perhaps something in the delivery handler<br><div>causes a channel-level error.</div><div>-- <br>MK<br><br><a href="http://github.com/michaelklishin" target="_blank">http://github.com/michaelklishin</a><br>
<a href="http://twitter.com/michaelklishin" target="_blank">http://twitter.com/michaelklishin</a><br>
</div></div></div>
<br></div></div><div class="im">_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com" target="_blank">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></div></blockquote></div><br></div>
</blockquote></div><br></div>