activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject [1/3] git commit: Fixes APLO-324: ConcurrentModificationException in recent snapshot
Date Fri, 31 Jan 2014 00:10:57 GMT
Updated Branches:
  refs/heads/trunk a325f0fbe -> a6629f94b


Fixes APLO-324: ConcurrentModificationException in recent snapshot

Project: http://git-wip-us.apache.org/repos/asf/activemq-apollo/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-apollo/commit/2fe48977
Tree: http://git-wip-us.apache.org/repos/asf/activemq-apollo/tree/2fe48977
Diff: http://git-wip-us.apache.org/repos/asf/activemq-apollo/diff/2fe48977

Branch: refs/heads/trunk
Commit: 2fe48977063c11709849d22b0fdbd34c1b7bf477
Parents: a325f0f
Author: Hiram Chirino <hiram@hiramchirino.com>
Authored: Thu Jan 30 16:13:03 2014 -0500
Committer: Hiram Chirino <hiram@hiramchirino.com>
Committed: Thu Jan 30 16:13:03 2014 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/apollo/stomp/StompProtocolHandler.scala   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-apollo/blob/2fe48977/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
----------------------------------------------------------------------
diff --git a/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
b/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
index 7854823..8c338b0 100644
--- a/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
+++ b/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
@@ -950,8 +950,9 @@ class StompProtocolHandler extends ProtocolHandler {
       })
       trace("stomp protocol resources released")
 
+      val route_values = producer_routes.values().toArray;
       waiting_on = ()=> {
-        val routes = producer_routes.values().flatMap { route =>
+        val routes = route_values.flatMap { route =>
           if( route.routing_items > 0 ) {
             Some(route.dest+"("+route.routing_items+")")
           } else {


Mime
View raw message