[jboss-remoting-commits] JBoss Remoting SVN: r6321 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/coyote.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2011-04-15 15:13:03 -0400 (Fri, 15 Apr 2011)
New Revision: 6321

Modified:
   remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/coyote/SetAttributeTestCase.java
Log:
Added tests for configuration of executor.


Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/coyote/SetAttributeTestCase.java
===================================================================
--- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/coyote/SetAttributeTestCase.java	2011-04-14 16:02:00 UTC (rev 6320)
+++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/coyote/SetAttributeTestCase.java	2011-04-15 19:13:03 UTC (rev 6321)
@@ -31,6 +31,7 @@
 
 import junit.framework.TestCase;
 
+import org.apache.catalina.core.StandardThreadExecutor;
 import org.apache.coyote.http11.Http11Protocol;
 import org.apache.log4j.ConsoleAppender;
 import org.apache.log4j.Level;
@@ -89,7 +90,7 @@
    }
    
    
-   public void testSetExecutor() throws Throwable
+   public void testSetProperties() throws Throwable
    {
       log.info("entering " + getName());
       
@@ -106,7 +107,7 @@
       log.info("Starting remoting server with locator uri of: " + locatorURI);
       HashMap config = new HashMap();
       config.put(InvokerLocator.FORCE_REMOTE, "true");
-      
+        
       // Attributes set directly on Http11Protocol
       config.put("maxSavePostSize", "3");
       config.put("keepAlive", "false");
@@ -117,6 +118,12 @@
       config.put("soTimeout", "7");
       config.put("tcpNoDelay", "true");
       config.put("address", InetAddress.getLocalHost());      
+
+      // Executor
+      String s = "daemon=false,maxIdleTime=11, minSpareThreads =13,maxThreads = 17 ,";
+      s += " name= test ,namePrefix=prefix,threadPriority=" + (Thread.NORM_PRIORITY + 1);
+      s += ", bogus=fake";
+      config.put("executor", s);
       
       connector = new Connector(serverLocator, config);
       connector.create();
@@ -145,6 +152,23 @@
       assertEquals(Boolean.TRUE, new Boolean(protocolHandler.getTcpNoDelay()));
       assertEquals(InetAddress.getLocalHost(), protocolHandler.getAddress());
       
+      StandardThreadExecutor executor = (StandardThreadExecutor) protocolHandler.getExecutor();
+      log.info("daemon:          " + executor.isDaemon());
+      log.info("maxIdleTime:     " + executor.getMaxIdleTime());
+      log.info("minSpareThreads: " + executor.getMinSpareThreads());
+      log.info("maxThreads:      " + executor.getMaxThreads());
+      log.info("name:            " + executor.getName());
+      log.info("namePrefix:      " + executor.getNamePrefix());
+      log.info("threadPriority:  " + executor.getThreadPriority());
+      
+      assertFalse(executor.isDaemon());
+      assertEquals(11, executor.getMaxIdleTime());
+      assertEquals(13, executor.getMinSpareThreads());
+      assertEquals(17, executor.getMaxThreads());
+      assertEquals("test", executor.getName());
+      assertEquals("prefix", executor.getNamePrefix());
+      assertEquals(Thread.NORM_PRIORITY + 1, executor.getThreadPriority());
+      
       if (connector != null)
          connector.stop();
       log.info(getName() + " PASSES");