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