+ * Copyright Apr 13, 2011 + */ +public class SetAttributeTestCase extends TestCase +{ + private static Logger log =3D Logger.getLogger(SetAttributeTestCase.cla= ss); + = + private static boolean firstTime =3D true; + = + protected String host; + protected int port; + protected String locatorURI; + protected InvokerLocator serverLocator; + protected Connector connector; + protected TestInvocationHandler invocationHandler; + + = + public void setUp() throws Exception + { + if (firstTime) + { + firstTime =3D false; + Logger.getLogger("org.jboss.remoting").setLevel(Level.INFO); + Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); + String pattern =3D "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; + PatternLayout layout =3D new PatternLayout(pattern); + ConsoleAppender consoleAppender =3D new ConsoleAppender(layout); + Logger.getRootLogger().addAppender(consoleAppender); = + } + } + + = + public void tearDown() + { + } + = + = + public void testSetProperties() throws Throwable + { + log.info("entering " + getName()); + = + // Start server. + host =3D InetAddress.getLocalHost().getHostAddress(); + port =3D PortUtil.findFreePort(host); + locatorURI =3D getTransport() + "://" + host + ":" + port; + String metadata =3D System.getProperty("remoting.metadata"); + if (metadata !=3D null) + { + locatorURI +=3D "/?" + metadata; + } + serverLocator =3D new InvokerLocator(locatorURI); + log.info("Starting remoting server with locator uri of: " + locatorU= RI); + HashMap config =3D new HashMap(); + config.put(InvokerLocator.FORCE_REMOTE, "true"); + = + // Attributes set directly on Http11Protocol + config.put("maxSavePostSize", "3"); + config.put("keepAlive", "false"); + config.put("compression", "on"); + config.put("testObject", new TestObject(5)); + = + // Attributes set on Http11Protocol.endpoint + config.put("soTimeout", "7"); + config.put("tcpNoDelay", "true"); + config.put("address", InetAddress.getLocalHost()); = + + // Executor + String s =3D "daemon=3Dfalse,maxIdleTime=3D11, minSpareThreads =3D13= ,maxThreads =3D 17 ,"; + s +=3D " name=3D test ,namePrefix=3Dprefix,threadPriority=3D" + (Thr= ead.NORM_PRIORITY + 1); + s +=3D ", bogus=3Dfake"; + config.put("executor", s); + = + connector =3D new Connector(serverLocator, config); + connector.create(); + invocationHandler =3D new TestInvocationHandler(); + connector.addInvocationHandler("test", invocationHandler); + connector.start(); + CoyoteInvoker invoker =3D (CoyoteInvoker) connector.getServerInvoker= (); + Field field =3D CoyoteInvoker.class.getDeclaredField("protocolHandle= rs"); + field.setAccessible(true); + List protocolHandlers =3D (List) field.get(invoker); + Http11Protocol protocolHandler =3D (Http11Protocol) protocolHandlers= .iterator().next(); + log.info("maxSavePostSize: " + protocolHandler.getMaxSavePostSize(= )); + log.info("keepAlive: " + protocolHandler.getKeepAlive()); + log.info("compression: " + protocolHandler.getCompression()); + log.info("testObject: " + protocolHandler.getAttribute("testO= bject")); + = + log.info("soTimeout: " + protocolHandler.getSoTimeout()); = + log.info("tcpNoDelay: " + protocolHandler.getTcpNoDelay()); + log.info("address: " + protocolHandler.getAddress()); + = + assertEquals(new Integer(3), new Integer(protocolHandler.getMaxSaveP= ostSize())); + assertEquals(Boolean.FALSE, new Boolean(protocolHandler.getKeepAlive= ())); + assertEquals("on", protocolHandler.getCompression()); + assertEquals(new TestObject(5), protocolHandler.getAttribute("testOb= ject")); + = + assertEquals(new Integer(7), new Integer(protocolHandler.getSoTimeou= t())); + assertEquals(Boolean.TRUE, new Boolean(protocolHandler.getTcpNoDelay= ())); + assertEquals(InetAddress.getLocalHost(), protocolHandler.getAddress(= )); + = + StandardThreadExecutor executor =3D (StandardThreadExecutor) protoco= lHandler.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 !=3D null) + connector.stop(); + log.info(getName() + " PASSES"); + } + = + = + protected String getTransport() + { + return "http"; + } + = + = + protected void addExtraClientConfig(Map config) {} + protected void addExtraServerConfig(Map config) {} + = + static class TestInvocationHandler implements ServerInvocationHandler + { + public void addListener(InvokerCallbackHandler callbackHandler) {} + public Object invoke(final InvocationRequest invocation) throws Thro= wable + { + return invocation.getParameter(); + } + public void removeListener(InvokerCallbackHandler callbackHandler) {} + public void setMBeanServer(MBeanServer server) {} + public void setInvoker(ServerInvoker invoker) {} + } + = + static class TestObject + { + private int secret; + public TestObject(int secret) {this.secret =3D secret;} + public boolean equals(Object o) + { + if (!(o instanceof TestObject)) return false; + return this.secret =3D=3D ((TestObject) o).secret; + } + public String toString() + { + return "TestObject(" + secret + ")"; + } + } +} \ No newline at end of file Property changes on: remoting2/branches/2.x/src/tests/org/jboss/test/remoti= ng/transport/coyote/SetAttributeTestCase.java ___________________________________________________________________ Added: svn:executable + * --===============7201969915027228708==--