[hornetq-commits] JBoss hornetq SVN: r11077 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl.

do-not-reply at jboss.org do-not-reply at jboss.org
Mon Aug 1 00:30:35 EDT 2011


Author: clebert.suconic at jboss.com
Date: 2011-08-01 00:30:35 -0400 (Mon, 01 Aug 2011)
New Revision: 11077

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
Log:
Fixing tests

Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-07-30 19:02:39 UTC (rev 11076)
+++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-08-01 04:30:35 UTC (rev 11077)
@@ -20,6 +20,7 @@
 import java.security.PrivilegedAction;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Collection;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
@@ -1314,11 +1315,13 @@
 
    private void updateArraysAndPairs()
    {
+      Collection<TopologyMember> membersCopy = topology.getMembers();
+      
       topologyArray = (Pair<TransportConfiguration, TransportConfiguration>[])Array.newInstance(Pair.class,
-                                                                                                topology.members());
+                                                                                                membersCopy.size());
 
       int count = 0;
-      for (TopologyMember pair : topology.getMembers())
+      for (TopologyMember pair : membersCopy)
       {
          topologyArray[count++] = pair.getConnector();
       }



More information about the hornetq-commits mailing list