You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Gary Tully (JIRA)" <ji...@apache.org> on 2018/08/02 13:38:01 UTC
[jira] [Updated] (AMQ-7030) unhandled CancellationException in
cursor duplicate detection logic
[ https://issues.apache.org/jira/browse/AMQ-7030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully updated AMQ-7030:
----------------------------
Description:
With concurrentStoreAndDispatchQueues true, a CancellationException can bubble up to pageIn in error.
{code:java}
Failed to page in more queue messages
java.util.concurrent.CancellationException
at java.util.concurrent.FutureTask.report(FutureTask.java:121)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.gotToTheStore(AbstractStoreCursor.java:136)
at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1993)
at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2177)
at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1627)
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748){code}
was:
With concurrentStoreAndDispatchQueues true, a
CancellationException can bubble up to pageIn in error.
{code:java}
Failed to page in more queue messages
java.util.concurrent.CancellationException
at java.util.concurrent.FutureTask.report(FutureTask.java:121)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.gotToTheStore(AbstractStoreCursor.java:136)
at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1993)
at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2177)
at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1627)
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748){code}
> unhandled CancellationException in cursor duplicate detection logic
> -------------------------------------------------------------------
>
> Key: AMQ-7030
> URL: https://issues.apache.org/jira/browse/AMQ-7030
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker, KahaDB
> Affects Versions: 5.15.0
> Reporter: Gary Tully
> Assignee: Gary Tully
> Priority: Major
> Fix For: 5.16.0
>
>
> With concurrentStoreAndDispatchQueues true, a CancellationException can bubble up to pageIn in error.
>
> {code:java}
> Failed to page in more queue messages
> java.util.concurrent.CancellationException
> at java.util.concurrent.FutureTask.report(FutureTask.java:121)
> at java.util.concurrent.FutureTask.get(FutureTask.java:192)
> at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.gotToTheStore(AbstractStoreCursor.java:136)
> at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1993)
> at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2177)
> at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1627)
> at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
> at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748){code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)