[hornetq-commits] JBoss hornetq SVN: r11584 - trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover.

do-not-reply at jboss.org do-not-reply at jboss.org
Tue Oct 25 08:30:43 EDT 2011


Author: borges
Date: 2011-10-25 08:30:43 -0400 (Tue, 25 Oct 2011)
New Revision: 11584

Modified:
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/NettyFailoverTest.java
Log:
clean up

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/NettyFailoverTest.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/NettyFailoverTest.java	2011-10-25 12:30:28 UTC (rev 11583)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/NettyFailoverTest.java	2011-10-25 12:30:43 UTC (rev 11584)
@@ -48,17 +48,13 @@
    {
       if (live)
       {
-         return new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory");
+         return new TransportConfiguration(NETTY_ACCEPTOR_FACTORY);
       }
-      else
-      {
-         Map<String, Object> server1Params = new HashMap<String, Object>();
 
-         server1Params.put(TransportConstants.PORT_PROP_NAME, TransportConstants.DEFAULT_PORT + 1);
+      Map<String, Object> server1Params = new HashMap<String, Object>();
+      server1Params.put(TransportConstants.PORT_PROP_NAME, TransportConstants.DEFAULT_PORT + 1);
 
-         return new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory",
-                                           server1Params);
-      }
+      return new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, server1Params);
    }
 
    @Override
@@ -66,17 +62,13 @@
    {
       if (live)
       {
-         return new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyConnectorFactory");
+         return new TransportConfiguration(NETTY_CONNECTOR_FACTORY);
       }
-      else
-      {
-         Map<String, Object> server1Params = new HashMap<String, Object>();
 
-         server1Params.put(TransportConstants.PORT_PROP_NAME, TransportConstants.DEFAULT_PORT + 1);
+      Map<String, Object> server1Params = new HashMap<String, Object>();
+      server1Params.put(TransportConstants.PORT_PROP_NAME, TransportConstants.DEFAULT_PORT + 1);
 
-         return new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyConnectorFactory",
-                                           server1Params);
-      }
+      return new TransportConfiguration(NETTY_CONNECTOR_FACTORY, server1Params);
    }
 
    // Private -------------------------------------------------------



More information about the hornetq-commits mailing list