[hornetq-commits] JBoss hornetq SVN: r11957 - in trunk: tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover and 1 other directory.

do-not-reply at jboss.org do-not-reply at jboss.org
Wed Jan 4 07:38:38 EST 2012


Author: borges
Date: 2012-01-04 07:38:37 -0500 (Wed, 04 Jan 2012)
New Revision: 11957

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java
Log:
Remove unused field and variables.

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java	2012-01-03 17:49:08 UTC (rev 11956)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java	2012-01-04 12:38:37 UTC (rev 11957)
@@ -1507,7 +1507,6 @@
 
    }
 
-   private static int size = 0;
    public class CloseRunnable implements Runnable
    {
       private final CoreRemotingConnection conn;

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java	2012-01-03 17:49:08 UTC (rev 11956)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java	2012-01-04 12:38:37 UTC (rev 11957)
@@ -22,17 +22,14 @@
 
 package org.hornetq.tests.integration.cluster.failover;
 
-import java.util.Map;
 import java.util.Set;
 
-import org.hornetq.api.core.TransportConfiguration;
 import org.hornetq.core.logging.Logger;
 import org.hornetq.core.server.HornetQServer;
 import org.hornetq.core.server.cluster.BroadcastGroup;
 import org.hornetq.core.server.cluster.impl.ClusterManagerImpl;
 import org.hornetq.spi.core.protocol.RemotingConnection;
 import org.hornetq.tests.integration.cluster.distribution.ClusterTestBase;
-import org.hornetq.tests.util.UnitTestCase;
 
 /**
  *
@@ -260,19 +257,6 @@
    {
       ClusterWithBackupFailoverTestBase.log.info("*** failing node " + node);
 
-      Map<String, Object> params = generateParams(node, isNetty());
-
-      TransportConfiguration serverTC;
-
-      if (isNetty())
-      {
-         serverTC = new TransportConfiguration(UnitTestCase.NETTY_CONNECTOR_FACTORY, params);
-      }
-      else
-      {
-         serverTC = new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY, params);
-      }
-
       HornetQServer server = getServer(node);
 
       // Prevent remoting service taking any more connections



More information about the hornetq-commits mailing list