Package org.xlightweb.server

Examples of org.xlightweb.server.HttpServer.addConnectionHandler()

127
128
129
130
131
132
133
134
135
136
137
   
    NonThreadedServerHandler hdl = new NonThreadedServerHandler();
   
    HttpServer server = new HttpServer(hdl);
    server.setConnectionTimeoutMillis(1 * 1000);
    server.addConnectionHandler(hdl);
    server.start();
   
    IBlockingConnection con = new BlockingConnection("localhost", server.getLocalPort());
   
    QAUtil.sleep(1000);
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
  public void testRequestMultithreaded() throws Exception {
    MultithreadedServerHandler hdl = new MultithreadedServerHandler();
   
    HttpServer server = new HttpServer(hdl);
    server.setRequestTimeoutMillis(1000);
    server.addConnectionHandler(hdl);
    server.start();
   
    IBlockingConnection con = new BlockingConnection("localhost", server.getLocalPort());
    con.write("GET / HTTP/1.1\r\n" +
          "Host: localhost\r\n" +
View Full Code Here
225
226
227
228
229
230
231
232
233
234
235
   
    NonThreadedServerHandler hdl = new NonThreadedServerHandler();
   
    HttpServer server = new HttpServer(hdl);
    server.setRequestTimeoutMillis(1000);
    server.addConnectionHandler(hdl);
    server.start();
   
    IBlockingConnection con = new BlockingConnection("localhost", server.getLocalPort());
    con.write("GET / HTTP/1.1\r\n" +
          "Host: localhost\r\n" +
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    System.out.println("testServersideDataReceiveTimeout");
   
    ItWorksRequestHandler itWorksHandler = new ItWorksRequestHandler();
    HttpServer server = new HttpServer(itWorksHandler);
    server.setBodyDataReceiveTimeoutMillis(500);
    server.addConnectionHandler(itWorksHandler);
    server.start();
   
    HttpProxy proxy =  new HttpProxy(0, "localhost", server.getLocalPort(), true, 60, 30);
    proxy.start();
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
   
    System.out.println("testClientSideResponseTimeout");
   
    SlowItWorksRequestHandler itWorksHandler = new SlowItWorksRequestHandler();
    HttpServer server = new HttpServer(itWorksHandler);
    server.addConnectionHandler(itWorksHandler);
    server.setBodyDataReceiveTimeoutMillis(500);
    server.start();
   
    HttpProxy proxy =  new HttpProxy(0, "localhost", server.getLocalPort(), true, 60, 30);
    proxy.start();
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
  public void testServerConnectDisconnect() throws Exception {
   
    HttpServer server = new HttpServer(new ItWorksServerHandler());
   
    ConnectionLifeCycleHandler lifecycleHandler = new ConnectionLifeCycleHandler();
    server.addConnectionHandler(lifecycleHandler);
   
    server.start();
 

View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
  public void testServerConnectDisconnect() throws Exception {
   
    HttpServer server = new HttpServer(new ItWorksServerHandler());
   
    ConnectionLifeCycleHandler lifecycleHandler = new ConnectionLifeCycleHandler();
    server.addConnectionHandler(lifecycleHandler);
   
    server.start();
 

View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
    System.out.println("testServersideDataReceiveTimeout");
   
    ItWorksRequestHandler itWorksHandler = new ItWorksRequestHandler();
    HttpServer server = new HttpServer(itWorksHandler);
    server.setBodyDataReceiveTimeoutMillis(500);
    server.addConnectionHandler(itWorksHandler);
    server.start();
   
    HttpProxy proxy =  new HttpProxy(0, "localhost", server.getLocalPort(), true, 60, 30);
    proxy.start();
View Full Code Here
329
330
331
332
333
334
335
336
337
338
339
   
    System.out.println("testClientSideResponseTimeout");
   
    SlowItWorksRequestHandler itWorksHandler = new SlowItWorksRequestHandler();
    HttpServer server = new HttpServer(itWorksHandler);
    server.addConnectionHandler(itWorksHandler);
    server.setBodyDataReceiveTimeoutMillis(500);
    server.start();
   
    HttpProxy proxy =  new HttpProxy(0, "localhost", server.getLocalPort(), true, 60, 30);
    proxy.start();
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
  public void testRequestMultithreaded() throws Exception {
    MultithreadedServerHandler hdl = new MultithreadedServerHandler();
   
    HttpServer server = new HttpServer(hdl);
    server.setRequestTimeoutMillis(1000);
    server.addConnectionHandler(hdl);
    server.start();
   
    IBlockingConnection con = new BlockingConnection("localhost", server.getLocalPort());
    con.write("GET / HTTP/1.1\r\n" +
          "Host: localhost\r\n" +
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.