<div dir="ltr">Hi Pavel,<div><br></div><div>Have you experimented with prefetch?</div><div><br></div><div>Which client are you using and which versions of rabbitmq and erlang. Message size is important too, of course.</div>
<div><br></div><div>We use the python pika client in asynch mode and have consistent processing times (fetch/process/publish) under 5ms.</div><div><br></div><div>In general, we have found event loop based approaches faster than threads, esp. on the small (cheap) machines we use in the cloud.</div>
<div><br></div><div>Best regards,</div><div><br></div><div>Michael</div></div><div class="gmail_extra"><br><br><div class="gmail_quote">On Wed, Jul 31, 2013 at 6:16 PM, Pavel Kogan <span dir="ltr"><<a href="mailto:pavel.kogan@cortica.com" target="_blank">pavel.kogan@cortica.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">Hi all,<div><br></div><div>I have simple subscriber that receives message, process it in single thread and publish response.</div>
<div>Processing must be done in single thread (logic limitations) but is very fast (~5ms) so I expect to be able to process 200 requests per second. However publishing response in line with processing slows the things as network latency is considerable (even though it is internal 1Gbit network). To resolve it I moved responses publishing to separate threads (via internal concurrent queue) and it helped.</div>
<div>The question is about receiving overhead. Is there any pre-caching of messages or I should also integrate internal concurrent queue for requests too?</div><div><br></div><div>Many Thanks,</div><div> Pavel</div></div>
<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>
<br></blockquote></div><br></div>