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

Reply via email to