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

[do-not-reply at jboss.org]

Author: clebert.suconic at 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];