[
https://issues.apache.org/activemq/browse/AMQ-1971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=46393#action_46393
]
Jayson Minard commented on AMQ-1971:
------------------------------------
Hey Rob, thanks for making a fix. A quick question about the
TopicStorePrefetch descendant class. It instantiates its own batchList which
then hides the ancestor one. IT looks like you removed the dispatched() method
which eliminates the previous issue I fixed and makes that part irrelevant.
But should the private batchList still be there in TopicStorePrefetch since it
now appears to be unused?
> ConcurrentModificationException in high volume broker
> ------------------------------------------------------
>
> Key: AMQ-1971
> URL: https://issues.apache.org/activemq/browse/AMQ-1971
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.2.0
> Reporter: Jayson Minard
> Assignee: Rob Davies
> Fix For: 5.3.0
>
> Attachments: amq1971.patch
>
>
> This is occurring in the thousands as messages come through. We have a
> network of 5 brokers although they do most of their work internally
> (publisher/consumer for queue are only on same broker) and do less work
> crossing to a central broker.
> java.util.ConcurrentModificationException
> at
> java.util.LinkedHashMap$LinkedHashIterator.nextEntry(LinkedHashMap.java:373)
> at java.util.LinkedHashMap$EntryIterator.next(LinkedHashMap.java:392)
> at java.util.LinkedHashMap$EntryIterator.next(LinkedHashMap.java:391)
> at
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor.next(AbstractStoreCursor.java:136)
> at
> org.apache.activemq.broker.region.cursors.StoreQueueCursor.next(StoreQueueCursor.java:140)
> at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1178)
> at
> org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1290)
> at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1004)
> at
> org.apache.activemq.thread.DeterministicTaskRunner.runTask(DeterministicTaskRunner.java:84)
> at
> org.apache.activemq.thread.DeterministicTaskRunner$1.run(DeterministicTaskRunner.java:41)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
