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; }