[APLO-324] ConcurrentModificationException in recent snapshot

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.7
• Environment: apollo-99-trunk-20130408.150706-222
• Assignee: Hiram R. Chirino
• Reporter: Lionel Cons
• Created: 21/May/13 06:53
• Updated: 31/Jan/14 16:17
• Resolved: 31/Jan/14 16:17

Description

One of our Apollo brokers logged the following:

2013-05-20 20:23:49,725 | WARN | HTTP request from '1.2.3.4' for GET '/broker' caused internal server error: java.util.ConcurrentModificationException | 13e1223a1e5

2013-05-20 20:23:49,775 | WARN | stackref=13e1223a1e5
java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextEntry(HashMap.java:793)
at java.util.HashMap$ValueIterator.next(HashMap.java:822)
at scala.collection.convert.Wrappers$JIteratorWrapper.next(Wrappers.scala:42)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1156)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:251)
at scala.collection.AbstractTraversable.flatMap(Traversable.scala:105)
at org.apache.activemq.apollo.stomp.StompProtocolHandler$$anonfun$disconnect$6.apply(StompProtocolHandler.scala:901)
at org.apache.activemq.apollo.stomp.StompProtocolHandler$$anonfun$disconnect$6.apply(StompProtocolHandler.scala:900)
at org.apache.activemq.apollo.stomp.StompProtocolHandler.create_connection_status(StompProtocolHandler.scala:776)
at org.apache.activemq.apollo.stomp.StompProtocolHandler.create_connection_status(StompProtocolHandler.scala:155)
at org.apache.activemq.apollo.broker.BrokerConnection.get_connection_status(Connection.scala:157)
at org.apache.activemq.apollo.broker.AcceptingConnector$$anonfun$status$5.apply(Connector.scala:160)
at org.apache.activemq.apollo.broker.AcceptingConnector$$anonfun$status$5.apply(Connector.scala:158)
at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
at scala.collection.mutable.LinkedHashMap.foreach(LinkedHashMap.scala:135)
at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
at org.apache.activemq.apollo.broker.AcceptingConnector.status(Connector.scala:158)
at org.apache.activemq.apollo.broker.AcceptingConnector.status(Connector.scala:117)
at org.apache.activemq.apollo.web.resources.BrokerResource$$anonfun$get_broker$1$$anonfun$apply$5$$anonfun$apply$9.apply(BrokerResource.scala:134)
at org.apache.activemq.apollo.web.resources.BrokerResource$$anonfun$get_broker$1$$anonfun$apply$5$$anonfun$apply$9.apply(BrokerResource.scala:132)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1156)
at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
at org.apache.activemq.apollo.web.resources.BrokerResource$$anonfun$get_broker$1$$anonfun$apply$5.apply(BrokerResource.scala:132)
at org.apache.activemq.apollo.web.resources.BrokerResource$$anonfun$get_broker$1$$anonfun$apply$5.apply(BrokerResource.scala:114)
at org.apache.activemq.apollo.util.package$$anonfun$sync$1.apply$mcV$sp(util.scala:59)
at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:357)
at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:96)
at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)

FWIW, the IP address corresponds to a Nagios instance monitoring this broker.