dblevins 2005/09/06 04:09:47
Modified: modules/core/src/test/org/openejb/server/httpd
HttpServerTest.java
Log:
Now using ActiveIO XNet for the xinetd style functionality
Revision Changes Path
1.10 +19 -21
openejb/modules/core/src/test/org/openejb/server/httpd/HttpServerTest.java
Index: HttpServerTest.java
===================================================================
RCS file:
/scm/openejb/openejb/modules/core/src/test/org/openejb/server/httpd/HttpServerTest.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- HttpServerTest.java 6 Aug 2005 21:33:55 -0000 1.9
+++ HttpServerTest.java 6 Sep 2005 08:09:47 -0000 1.10
@@ -44,29 +44,27 @@
*/
package org.openejb.server.httpd;
-import java.net.HttpURLConnection;
-import java.net.InetAddress;
-import java.net.URL;
-
-import javax.management.ObjectName;
-
import junit.framework.TestCase;
-
+import org.activeio.xnet.ServerService;
+import org.activeio.xnet.ServiceDaemon;
+import org.activeio.xnet.StandardServiceStack;
+import org.activeio.xnet.StandardServiceStackGBean;
+import org.activeio.xnet.SyncChannelServerDaemon;
import org.apache.geronimo.gbean.GBeanData;
import org.apache.geronimo.gbean.GBeanInfo;
import org.apache.geronimo.gbean.GBeanInfoBuilder;
import org.apache.geronimo.kernel.GBeanAlreadyExistsException;
import org.apache.geronimo.kernel.GBeanNotFoundException;
-import org.apache.geronimo.kernel.KernelFactory;
import org.apache.geronimo.kernel.Kernel;
+import org.apache.geronimo.kernel.KernelFactory;
import org.apache.geronimo.kernel.jmx.JMXUtil;
import org.apache.geronimo.kernel.management.State;
import org.apache.geronimo.pool.ThreadPool;
-import org.openejb.server.ServerService;
-import org.openejb.server.ServiceDaemon;
-import org.openejb.server.StandardServiceStack;
-import org.openejb.server.StandardServiceStackGBean;
-import org.openejb.server.SynchChannelServerDaemon;
+
+import javax.management.ObjectName;
+import java.net.HttpURLConnection;
+import java.net.InetAddress;
+import java.net.URL;
public class HttpServerTest extends TestCase {
@@ -97,7 +95,7 @@
public void testBareChannelService() throws Exception {
ServerService service = new HttpServer(new TestHttpListener());
- SynchChannelServerDaemon daemon = new
SynchChannelServerDaemon("HTTP", service, InetAddress.getByName("localhost"),
0);
+ SyncChannelServerDaemon daemon = new SyncChannelServerDaemon("HTTP",
service, InetAddress.getByName("localhost"), 0);
HttpURLConnection connection = null;
try {
@@ -111,7 +109,7 @@
int responseCode = connection.getResponseCode();
assertEquals("HTTP response code should be 204",
HttpURLConnection.HTTP_NO_CONTENT, responseCode);
} finally {
- if (connection != null ) {
+ if (connection != null) {
connection.disconnect();
}
daemon.doStop();
@@ -123,7 +121,7 @@
ServerService service = new HttpServer(new TestHttpListener());
ThreadPool threadPool = new ThreadPool(1, "Test", 1000,
getClass().getClassLoader(), "openejb:type=ThreadPool,name=Test");
-
+
StandardServiceStack serviceStack = new StandardServiceStack("HTTP",
0, "localhost", null, null, null, threadPool, service);
HttpURLConnection connection = null;
@@ -179,7 +177,7 @@
ObjectName listener = TestHttpListener.addGBean(kernel, "HTTP");
ObjectName server = HttpServerGBean.addGBean(kernel, "HTTP",
listener);
-
+
ClassLoader cl = ThreadPool.class.getClassLoader();
ObjectName executor =
JMXUtil.getObjectName("openejb:name=ThreadPool");
GBeanData gbean = new GBeanData(executor, ThreadPool.GBEAN_INFO);
@@ -199,8 +197,8 @@
HttpURLConnection connection = null;
try {
- kernel.setAttribute(stack,"soTimeout",new Integer(100));
- int port = ((Integer)kernel.getAttribute(stack,
"port")).intValue();
+ kernel.setAttribute(stack, "soTimeout", new Integer(100));
+ int port = ((Integer) kernel.getAttribute(stack,
"port")).intValue();
URL url = new URL("http://localhost:" + port +
"/this/should/hit/something");
connection = (HttpURLConnection) url.openConnection();
@@ -208,7 +206,7 @@
System.out.println("responseCode = " + responseCode);
assertEquals("HTTP response code should be 204", responseCode,
HttpURLConnection.HTTP_NO_CONTENT);
} catch (Exception e) {
- System.out.println("exception "+e.getMessage());
+ System.out.println("exception " + e.getMessage());
} finally {
connection.disconnect();
kernel.stopGBean(stack);