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