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