[hornetq-commits] JBoss hornetq SVN: r11708 - trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-11-18 05:46:53 -0500 (Fri, 18 Nov 2011)
New Revision: 11708

Modified:
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
Fix type warnings

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-11-18 10:46:38 UTC (rev 11707)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-11-18 10:46:53 UTC (rev 11708)
@@ -1243,7 +1243,7 @@
          Assert.assertTrue(counts.contains(messageCount));
       }
 
-      LinkedList[] lists = new LinkedList[consumerIDs.length];
+      List<LinkedList<Integer>> lists = new ArrayList<LinkedList<Integer>>(consumerIDs.length);
 
       for (int i = 0; i < messageCounts.length; i++)
       {
@@ -1253,7 +1253,7 @@
 
             if (elem == messageCounts[i])
             {
-               lists[i] = list;
+               lists.set(i, list);
 
                break;
             }
@@ -1263,17 +1263,17 @@
 
       for (int messageCount : messageCounts)
       {
-         LinkedList list = lists[index];
+         LinkedList<Integer> list = lists.get(index);
 
          Assert.assertNotNull(list);
 
-         int elem = (Integer)list.poll();
+         int elem = list.poll();
 
          Assert.assertEquals(messageCount, elem);
 
          index++;
 
-         if (index == lists.length)
+         if (index == consumerIDs.length)
          {
             index = 0;
          }