<div dir="ltr">I try this at init step:<div><br></div><div><div> _connection = _connectionFactory.CreateConnection();</div><div> _channel = _connection.CreateModel(); </div><div> _channel.BasicQos(0, 1, false); //params are: prefetchSize, prefetchCount, global</div>
<div> _basicConsumer = new QueueingBasicConsumer(_channel) {ConsumerTag = GetTag()};</div></div><div><br></div><div>and now I can only read one first message from A. When I try to read first message from B I have exactly same problem.</div>
<div><br></div><div>_channel.BasicQos(0, 1, false); method call I took from old .NET client docs.<br></div><div><br></div><div>Thanks.</div></div><div class="gmail_extra"><br><br><div class="gmail_quote">2013/8/22 Michael Klishin <span dir="ltr"><<a href="mailto:mklishin@gopivotal.com" target="_blank">mklishin@gopivotal.com</a>></span><br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Valentin Polezhaev:<br>
<div class="im"><br>
> My code successfully reads first messages from both A and B queues, but third time (second read from A) it stays at line<br>
> var ea = (BasicDeliverEventArgs) _basicConsumer.Queue.Dequeue();<br>
> and nothing happens.<br>
<br>
</div>Just to clarify:<br>
<br>
this particular behavior is likely due to the following: both messages in A were already delivered,<br>
and take off the (internal to the client) linked queue, so subsequent invocations<br>
will block the caller until a new delivery arrives.<br>
--<br>
MK<br>
<br>
</blockquote></div><br><br clear="all"><div><br></div>-- <br>With best regards, Valentin.
</div>