[
https://issues.apache.org/jira/browse/JAMES-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628067#comment-17628067
]
Benoit Tellier commented on JAMES-3848:
---------------------------------------
I would welcome a patch giving a try at this!
> ActiveMQ dequeuing can block (infinite timeout)
> -----------------------------------------------
>
> Key: JAMES-3848
> URL: https://issues.apache.org/jira/browse/JAMES-3848
> Project: James Server
> Issue Type: Improvement
> Components: Queue
> Reporter: ouvtam
> Priority: Minor
>
> While working on JAMES-3841 I stumbled upon blocking code that might need
> some investigation.
> When calling ActiveMQMessageConsumer#receive(timeout) it blocks until a new
> message is received when prefetchSize is zero (see
> org.apache.activemq.ActiveMQMessageConsumer#receive) even when a timeout is
> given. That would explain some observed timeouts in disabled tests in the
> test package org.apache.james.queue.activemq.
> One way to mitigate this is to set prefetch size greater than zero to make
> the timeout occur. But this would also mean that code that relies on blocking
> dequeues must be rewritten.
> What do you think?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
