<div dir="ltr">MK,<div><br></div><div>Not sure I understand. "Make sure your code is prepared for that." What do you mean by that. Also, if thread pool, will it close once the broker receive a "basicAck"?</div>
</div><div class="gmail_extra"><br><br><div class="gmail_quote">On Fri, Feb 7, 2014 at 2:29 AM, Michael Klishin <span dir="ltr"><<a href="mailto:mklishin@gopivotal.com" target="_blank">mklishin@gopivotal.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div class="im"><br>
On 7 Feb 2014, at 05:00, cw storm <<a href="mailto:cwstorm@gmail.com">cwstorm@gmail.com</a>> wrote:<br>
<br>
> It has to be done inside the "handleDelivery". It works if I perform the "doInvoke" outside of the "handleDelivery".<br>
><br>
> try {<br>
> channel.basicConsume(strQueueName, false,<br>
> new DefaultConsumer(channel) {<br>
> @Override<br>
> public void handleDelivery(String consumerTag,<br>
> Envelope envelope,<br>
> AMQP.BasicProperties props,<br>
> byte[] body)<br>
> throws IOException<br>
> {<br>
><br>
> try<br>
> {<br>
> Service.doInvoke(NSName, pipeline);<br>
> }<br>
> catch (Exception e) {<br>
> }<br>
> }<br>
> });<br>
> } catch (Exception e1) {<br>
> }<br>
<br>
</div>Deliveries are dispatched to a thread pool (j.u.c. executor service). Make sure your code<br>
is prepared for that. Also, posting a stack trace would help.<br>
<br>
MK<br>
<br>
Software Engineer, Pivotal/RabbitMQ<br>
<br>
<br>
_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">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>
</blockquote></div><br></div>