[hornetq-commits] JBoss hornetq SVN: r11957 - in trunk: tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover and 1 other directory.
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