You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "ASF subversion and git services (JIRA)" <ji...@apache.org> on 2018/08/02 13:47:00 UTC
[jira] [Commented] (AMQ-7030) unhandled CancellationException in
cursor duplicate detection logic
[ https://issues.apache.org/jira/browse/AMQ-7030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566830#comment-16566830 ]
ASF subversion and git services commented on AMQ-7030:
------------------------------------------------------
Commit bdfa3394adddd011c7d978d5a086fa3bcdaf1b41 in activemq's branch refs/heads/master from gtully
[ https://git-wip-us.apache.org/repos/asf?p=activemq.git;h=bdfa339 ]
AMQ-7030 - trap exceptions on future.get, fix and test
> 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)