[hornetq-commits] JBoss hornetq SVN: r8515 - in trunk/tests/src/org/hornetq/tests: util and 1 other directory.

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Dec 3 02:25:42 EST 2009


Author: clebert.suconic at jboss.com
Date: 2009-12-03 02:25:42 -0500 (Thu, 03 Dec 2009)
New Revision: 8515

Modified:
   trunk/tests/src/org/hornetq/tests/integration/client/NettyConsumerWindowSizeTest.java
   trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java
Log:
tweaks / fixing compilation

Modified: trunk/tests/src/org/hornetq/tests/integration/client/NettyConsumerWindowSizeTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/NettyConsumerWindowSizeTest.java	2009-12-03 07:22:04 UTC (rev 8514)
+++ trunk/tests/src/org/hornetq/tests/integration/client/NettyConsumerWindowSizeTest.java	2009-12-03 07:25:42 UTC (rev 8515)
@@ -13,14 +13,7 @@
 
 package org.hornetq.tests.integration.client;
 
-import java.util.HashMap;
 
-import org.hornetq.core.client.ClientSessionFactory;
-import org.hornetq.core.client.impl.ClientSessionFactoryImpl;
-import org.hornetq.core.config.Configuration;
-import org.hornetq.core.config.TransportConfiguration;
-import org.hornetq.integration.transports.netty.TransportConstants;
-
 /**
  * A NettyConsumerWindowSizeTest
  *
@@ -40,39 +33,6 @@
       return true;
    }
    
-   protected ClientSessionFactory createNettyFactory()
-   {
-      HashMap<String, Object> parameters = new HashMap<String, Object>();
-      
-      parameters.put(TransportConstants.TCP_NODELAY_PROPNAME, true);
-      
-      TransportConfiguration config = new TransportConfiguration(NETTY_CONNECTOR_FACTORY, parameters);
-      
-      return new ClientSessionFactoryImpl(config);
-      
-      //return super.createNettyFactory();
-   }
-
-   protected Configuration createDefaultConfig(final boolean netty)
-   {
-      if (netty)
-      {
-         
-         HashMap<String, Object> parameters = new HashMap<String, Object>();
-         
-         parameters.put(TransportConstants.TCP_NODELAY_PROPNAME, true);
-
-         return createDefaultConfig(parameters, INVM_ACCEPTOR_FACTORY, NETTY_ACCEPTOR_FACTORY);
-      }
-      else
-      {
-         new Exception("This test wasn't supposed to use InVM").printStackTrace();
-         return super.createDefaultConfig(false);
-      }
-   }
-
-
-
    // Static --------------------------------------------------------
 
    // Constructors --------------------------------------------------

Modified: trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java	2009-12-03 07:22:04 UTC (rev 8514)
+++ trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java	2009-12-03 07:25:42 UTC (rev 8515)
@@ -318,7 +318,7 @@
       return configuration;
    }
 
-   protected ClientSessionFactory createFactory(boolean isNetty)
+   protected ClientSessionFactoryImpl createFactory(boolean isNetty)
    {
       if (isNetty)
       {
@@ -330,17 +330,17 @@
       }
    }
 
-   protected ClientSessionFactory createInVMFactory()
+   protected ClientSessionFactoryImpl createInVMFactory()
    {
       return createFactory(INVM_CONNECTOR_FACTORY);
    }
 
-   protected ClientSessionFactory createNettyFactory()
+   protected ClientSessionFactoryImpl createNettyFactory()
    {
       return createFactory(NETTY_CONNECTOR_FACTORY);
    }
 
-   protected ClientSessionFactory createFactory(final String connectorClass)
+   protected ClientSessionFactoryImpl createFactory(final String connectorClass)
    {
       return new ClientSessionFactoryImpl(new TransportConfiguration(connectorClass), null);
 



More information about the hornetq-commits mailing list