Package org.xlightweb.client

Examples of org.xlightweb.client.HttpClientConnection.send()

52
53
54
55
56
57
58
59
60
61
62
     
      HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
      con.setOption(IConnection.SO_RCVBUF, 64);
     
      FutureResponseHandler rh = new FutureResponseHandler();
      BodyDataSink clientDataSink = con.send(new HttpRequestHeader("POST", "text/plain"), rh);
      clientDataSink.setFlushmode(FlushMode.ASYNC);
     
      clientDataSink.write(QAUtil.generateByteArray(300));
      QAUtil.sleep(500);
     
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
       
       
        HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());

        OnHeaderReceivedResponseHandler respHdl = new OnHeaderReceivedResponseHandler();
        con.send(new GetRequest("http://localhost:" + server.getLocalPort() + "/"), respHdl);
       
        QAUtil.sleep(1000);
        Assert.assertEquals(200, respHdl.responseRef.get().getStatus());
        Assert.assertEquals(0, respHdl.responseRef.get().getNonBlockingBody().available());
       
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
       
       
        HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());

        OnMessageReceivedResponseHandler respHdl = new OnMessageReceivedResponseHandler();
        con.send(new GetRequest("http://localhost:" + server.getLocalPort() + "/"), respHdl);
       
        QAUtil.sleep(1000);
        Assert.assertNull(respHdl.responseRef.get());
       
        QAUtil.sleep(3000);
View Full Code Here
294
295
296
297
298
299
300
301
302
303
304
        con.setBodyDataReceiveTimeoutMillis(5000);
       
       
        for (int i = 0; i < 1000; i++) {
            FutureResponseHandler respHdl = new FutureResponseHandler();
            BodyDataSink dataSink = con.send(new HttpRequestHeader("POST", "http://localhost:" + container.getLocalPort() + "/test"), respHdl);
           
            dataSink.write("test");
           
            IHttpResponse response = respHdl.getResponse();
            Assert.assertEquals(200, response.getStatus());
View Full Code Here
330
331
332
333
334
335
336
337
338
339
340
        HttpClientConnection con = new HttpClientConnection("localhost", container.getLocalPort());

        FutureResponseHandler respHdl = new FutureResponseHandler();
        HttpRequestHeader header = new HttpRequestHeader("POST", "http://localhost:" + container.getLocalPort() + "/test");
        header.setHeader("connection", "close");
        BodyDataSink dataSink = con.send(header, respHdl);
       
        dataSink.write("test");
       
        IHttpResponse response = respHdl.getResponse();
        Assert.assertEquals(200, response.getStatus());
View Full Code Here
364
365
366
367
368
369
370
371
372
373
374
        HttpClientConnection con = new HttpClientConnection("localhost", container.getLocalPort());

       
        for (int i = 0; i < 100; i++) {
            final FutureResponseHandler respHdl = new FutureResponseHandler();
            final BodyDataSink dataSink = con.send(new HttpRequestHeader("POST", "http://localhost:" + container.getLocalPort() + "/test"), respHdl);
            dataSink.setFlushmode(FlushMode.ASYNC);
           
           
            IWriteCompletionHandler completionHandler1 = new IWriteCompletionHandler() {
               
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
 
       
    FutureResponseHandler hdl = new FutureResponseHandler();
   
    BodyDataSink sink = con.send(new HttpRequestHeader("POST", "/", "text/plain; charset=iso-8859-1"), hdl);
    sink.flush();
   
    BlockingBodyDataSource source = hdl.getResponse().getBlockingBody();
   
    sink.write("test\r\n");
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        con.setIdleTimeoutMillis(1000);
       
        HttpClientConnection httpCon = new HttpClientConnection(con);
       
        ResponseHandler respHdl = new ResponseHandler();
        httpCon.send(new GetRequest("/"), respHdl);
       
        QAUtil.sleep(2000);
        Assert.assertTrue(respHdl.getException() instanceof SocketTimeoutException);
       
        server.close();  
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
        con.setIdleTimeoutMillis(1000);
       
        HttpClientConnection httpCon = new HttpClientConnection(con);
       
        ResponseHandler2 respHdl = new ResponseHandler2();
        httpCon.send(new GetRequest("/"), respHdl);
       
        QAUtil.sleep(2000);
        Assert.assertTrue(respHdl.getException() instanceof SocketTimeoutException);
       
        server.close();
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
     
      HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
      con.setOption(IConnection.SO_RCVBUF, 64);
     
      FutureResponseHandler rh = new FutureResponseHandler();
      BodyDataSink clientDataSink = con.send(new HttpRequestHeader("POST", "text/plain"), rh);
      clientDataSink.setFlushmode(FlushMode.ASYNC);
     
      clientDataSink.write(QAUtil.generateByteArray(300));
      QAUtil.sleep(500);
     
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.