Author: clebert.suconic(a)jboss.com
Date: 2009-11-06 09:34:10 -0500 (Fri, 06 Nov 2009)
New Revision: 8240
Modified:
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
small tweak
Modified:
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-06
13:31:14 UTC (rev 8239)
+++
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-06
14:34:10 UTC (rev 8240)
@@ -88,6 +88,14 @@
checkFreePort(PORTS);
clearData();
+
+ consumers = new ConsumerHolder[MAX_CONSUMERS];
+
+ servers = new HornetQServer[MAX_SERVERS];
+
+ sfs = new ClientSessionFactory[MAX_SERVERS];
+
+
}
@Override
@@ -124,18 +132,18 @@
}
}
- private ConsumerHolder[] consumers = new ConsumerHolder[MAX_CONSUMERS];
-
private static final SimpleString COUNT_PROP = new
SimpleString("count_prop");
protected static final SimpleString FILTER_PROP = new
SimpleString("animal");
private static final int MAX_SERVERS = 10;
- protected HornetQServer[] servers = new HornetQServer[MAX_SERVERS];
+ private ConsumerHolder[] consumers;
- protected ClientSessionFactory[] sfs = new ClientSessionFactory[MAX_SERVERS];
+ protected HornetQServer[] servers;
+ protected ClientSessionFactory[] sfs;
+
protected void waitForMessages(int node, final String address, final int count) throws
Exception
{
HornetQServer server = this.servers[node];