Sleep in consumer

[carlhoerberg]

More of a question than an issue; seems like (Thread/sleep 10000) in a subscription handler returns immediately, is that right? In that case, why/how?

[michaelklishin]

No. How can Langohr affect behavior of JDK classes like Thread?

[carlhoerberg]

I know Langohr doesn't do anything, more if you knew if ExecutorService did something to thread/sleep..

[ifesdjeen]

It may just look like that is happening. ExecutorService doesn't do anything to Thread/sleep, so it should work as expected.

Try using some logger (or rebinding out to stdout so that all the threads could println) and going through what's going on within your handler.

Maybe I misunderstood the question. So far, worked quite fine for me, let me know if that helps or if you have some more info or an example.

[carlhoerberg]

yeah, no, that's what i'm doing, (println "a") (Thread/sleep 10000) (println "b"), but both a and b is printed to the log at the same time.. but ok, might be something else interfering then. thank you.

On Monday 24 June 2013 at 10:19, Alex P wrote:

It may just look like that is happening. ExecutorService doesn't do anything to Thread/sleep, so it should work as expected.
Try using some logger (or rebinding out to stdout so that all the threads could println) and going through what's going on within your handler.
Maybe I misunderstood the question. So far, worked quite fine for me, let me know if that helps or if you have some more info or an example.

—
Reply to this email directly or view it on GitHub (#18 (comment)).

[michaelklishin]

Consumer deliveries are dispatched to an executor which in theory may interrupt or otherwise wake up sleeping threads, although I haven't heard of anything like that. But a sleeping thread can be interrupted.

[carlhoerberg]

when trying to isolate and replicate the behavior (which so far i'm unable to do so), i noticed that messages aren't processed in parallel, even with a custom ExecutorService (20 fixed threads), is that expected? (qos > 1)

On Tuesday 25 June 2013 at 11:12, Michael Klishin wrote:

Consumer deliveries are dispatched to an executor which in theory may interrupt or otherwise wake up sleeping threads, although I haven't heard of anything like that. But a sleeping thread can be interrupted.

—
Reply to this email directly or view it on GitHub (#18 (comment)).