[hornetq-commits] JBoss hornetq SVN: r11746 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/reattach.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-11-23 11:14:50 -0500 (Wed, 23 Nov 2011)
New Revision: 11746

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/reattach/NettyMultiThreadRandomReattachTest.java
Log:
Using NIO on the NettyReattachTest

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/reattach/NettyMultiThreadRandomReattachTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/reattach/NettyMultiThreadRandomReattachTest.java	2011-11-23 10:36:50 UTC (rev 11745)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/reattach/NettyMultiThreadRandomReattachTest.java	2011-11-23 16:14:50 UTC (rev 11746)
@@ -13,10 +13,14 @@
 
 package org.hornetq.tests.integration.cluster.reattach;
 
+import java.util.HashMap;
+import java.util.Map;
+
 import org.hornetq.api.core.TransportConfiguration;
 import org.hornetq.api.core.client.HornetQClient;
 import org.hornetq.api.core.client.ServerLocator;
 import org.hornetq.core.config.Configuration;
+import org.hornetq.core.remoting.impl.netty.TransportConstants;
 import org.hornetq.core.server.HornetQServers;
 
 /**
@@ -37,8 +41,12 @@
       liveConf.setJMXManagementEnabled(false);
       liveConf.setSecurityEnabled(false);
       liveConf.getAcceptorConfigurations().clear();
+      
+      Map<String, Object> connectionParams = new HashMap<String, Object>();
+      connectionParams.put(TransportConstants.USE_NIO_PROP_NAME, true);
+
       liveConf.getAcceptorConfigurations()
-              .add(new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory"));
+              .add(new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory", connectionParams));
       liveServer = HornetQServers.newHornetQServer(liveConf, false);
       liveServer.start();
    }
@@ -46,11 +54,15 @@
    @Override
    protected ServerLocator createLocator() throws Exception
    {
-      ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyConnectorFactory")) ;
+      Map<String, Object> connectionParams = new HashMap<String, Object>();
+      connectionParams.put(TransportConstants.USE_NIO_PROP_NAME, true);
+
+
+      ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration("org.hornetq.core.remoting.impl.netty.NettyConnectorFactory", connectionParams)) ;
       locator.setReconnectAttempts(-1);
       locator.setConfirmationWindowSize(1024 * 1024);
       locator.setAckBatchSize(0);
       return  locator;
    }
-
+   
 }