Author: ron.sigal(a)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");