activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jayson Minard (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQ-1971) ConcurrentModificationException in high volume broker
Date Sun, 12 Oct 2008 19:51:52 GMT

    [ https://issues.apache.org/activemq/browse/AMQ-1971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=46384#action_46384
] 

Jayson Minard commented on AMQ-1971:
------------------------------------

Queues form admin console look like this at time of failure (note that the admin UI now truncates
queue names for display making most unreadable and unusable in the display).  Note that some
queue sizes are negative numbers which we've seen before but not tracked down to anything
specific.

<queues>

<queue name="mag.query1.queue.record.physical">

  <stats size="-2" consumerCount="10" enqueueCount="29610" dequeueCount="29612"/>


  <feed>
    <atom>queueBrowse/mag.query1.queue.record.physical?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.query1.queue.record.physical?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.query1.queue.record.physical.pdf">

  <stats size="6" consumerCount="0" enqueueCount="6" dequeueCount="0"/>


  <feed>
    <atom>queueBrowse/mag.query1.queue.record.physical.pdf?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.query1.queue.record.physical.pdf?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.queue.record.search.zh">

  <stats size="0" consumerCount="10" enqueueCount="10" dequeueCount="10"/>


  <feed>
    <atom>queueBrowse/mag.queue.record.search.zh?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.queue.record.search.zh?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.queue.record.search.en">

  <stats size="-7" consumerCount="10" enqueueCount="29602" dequeueCount="29609"/>


  <feed>
    <atom>queueBrowse/mag.queue.record.search.en?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.queue.record.search.en?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.Events.Errors">

  <stats size="0" consumerCount="1" enqueueCount="8" dequeueCount="8"/>


  <feed>
    <atom>queueBrowse/mag.Events.Errors?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.Events.Errors?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.queue.record.logical">

  <stats size="0" consumerCount="1" enqueueCount="29612" dequeueCount="29612"/>


  <feed>
    <atom>queueBrowse/mag.queue.record.logical?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.queue.record.logical?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="test.existingRecordQueue">

  <stats size="0" consumerCount="1" enqueueCount="0" dequeueCount="0"/>


  <feed>
    <atom>queueBrowse/test.existingRecordQueue?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/test.existingRecordQueue?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.query1.queue.record.raw">

  <stats size="138407" consumerCount="50" enqueueCount="168029" dequeueCount="29622"/>


  <feed>
    <atom>queueBrowse/mag.query1.queue.record.raw?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.query1.queue.record.raw?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="example.A">

  <stats size="0" consumerCount="1" enqueueCount="0" dequeueCount="0"/>


  <feed>
    <atom>queueBrowse/example.A?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/example.A?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.query1.queue.record.physical.augment">

  <stats size="0" consumerCount="1" enqueueCount="27311" dequeueCount="27311"/>


  <feed>
    <atom>queueBrowse/mag.query1.queue.record.physical.augment?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.query1.queue.record.physical.augment?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

<queue name="mag.queue.record.search.other">

  <stats size="0" consumerCount="10" enqueueCount="0" dequeueCount="0"/>


  <feed>
    <atom>queueBrowse/mag.queue.record.search.other?view=rss&amp;feedType=atom_1.0</atom>
    <rss>queueBrowse/mag.queue.record.search.other?view=rss&amp;feedType=rss_2.0</rss>
  </feed>
</queue>

</queues>

> 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
>
> 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.


Mime
View raw message