Package org.xlightweb.client

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

203
204
205
206
207
208
209
210
211
212
213
       
        HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
       
   
        FutureResponseHandler respHandler = new FutureResponseHandler();
        BodyDataSink dataSink = con.send(new HttpRequestHeader("POST", "http://localhost:" + server.getLocalPort() + "/?isSuspend=true&durationMillis=2000"), respHandler);
       
        StringBuilder sb = new StringBuilder();
       
        for (int i = 1; i < 20; i++) {
            String data = new String(QAUtil.generateByteArray(22 * i));
 
View Full Code Here
239
240
241
242
243
244
245
246
247
248
249
       
        HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
       
   
        FutureResponseHandler respHandler = new FutureResponseHandler();
        BodyDataSink dataSink = con.send(new HttpRequestHeader("POST", "http://localhost:" + server.getLocalPort() + "/?isSuspend=true&durationMillis=2000"), respHandler);
       
        StringBuilder sb = new StringBuilder();
       
        for (int i = 1; i < 2; i++) {
            String data = new String(QAUtil.generateByteArray(222000 * i));
 
View Full Code Here
343
344
345
346
347
348
349
350
351
352
353
        HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
       
        File file = QAUtil.createTestfile_40k();
       
        FutureResponseHandler respHdl = new FutureResponseHandler();
        BodyDataSink dataSink = con.send(new HttpRequestHeader("POST", "http://localhost:" + server.getLocalPort() + "/"), respHdl);
          
        RandomAccessFile raf = new RandomAccessFile(file, "r");
        AsyncWriter writer = new AsyncWriter(dataSink, raf);
        writer.onWritten(0);
       
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
        requestHeader.setHeader("Expect", "100-Continue");
       
    
        String data = "1234567890";
        ResponseHandlerContinueNotSupported respHdl = new ResponseHandlerContinueNotSupported(data);
        BodyDataSink dataSink = con.send(requestHeader, respHdl);
        respHdl.setBodyDataSink(dataSink);
        dataSink.flush();
       
        while ((respHdl.getLastResponse() == null)) {
            QAUtil.sleep(100);
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
        requestHeader.setHeader("Expect", "100-Continue");
       
    
        String data = "test1234567890";
        ResponseHandler respHdl = new ResponseHandler(data);
        BodyDataSink dataSink = con.send(requestHeader, respHdl);
        respHdl.setBodyDataSink(dataSink);
        dataSink.flush();

       
        while ((respHdl.getLastResponse() == null) || (respHdl.getLastResponse().getStatus() == 100)) {
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
        requestHeader.setHeader("Expect", "100-Continue");
       
    
        String data = "test1234567890";
        ResponseHandlerContinueNotSupported respHdl = new ResponseHandlerContinueNotSupported(data);
        BodyDataSink dataSink = con.send(requestHeader, respHdl);
        respHdl.setBodyDataSink(dataSink);
        dataSink.flush();
       
        while ((respHdl.getLastResponse() == null)) {
            QAUtil.sleep(100);
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
       
        HttpRequestHeader requestHeader = new HttpRequestHeader("POST", "http://localhost:" + server3.getLocalPort() + "/test", "text/plain; charset=iso-8859-1");
       
        String data = "test1234567890";
        FutureResponseHandler respHdl = new FutureResponseHandler();
        BodyDataSink dataSink = con.send(requestHeader, data.length(), respHdl);
        dataSink.write("test1234567890");
       
        IHttpResponse response = respHdl.getResponse();
       
        Assert.assertEquals(200, response.getStatus());
View Full Code Here
307
308
309
310
311
312
313
314
315
316
317
        requestHeader.setHeader("Expect", "100-Continue");
       
    
        String data = "test1234567890";
        ResponseHandler respHdl = new ResponseHandler(data);
        BodyDataSink dataSink = con.send(requestHeader, respHdl);
        respHdl.setBodyDataSink(dataSink);
        dataSink.flush();
       

        while ((respHdl.getLastResponse() == null) || (respHdl.getLastResponse().getStatus() == 100)) {
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
   
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
   
    ThreadedResponseHandler tHandler = new ThreadedResponseHandler();
    con.send(new GetRequest("/"), tHandler);
   
    QAUtil.sleep(1000);
    Assert.assertTrue(tHandler.getResponse().getStatus() == 200);
    Assert.assertFalse(tHandler.getThreadname().startsWith("xDispatcher"));
   
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
   
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
   
    NonThreadedResponseHandler tHandler = new NonThreadedResponseHandler();
    con.send(new GetRequest("/"), tHandler);
   
    QAUtil.sleep(1000);
    Assert.assertTrue(tHandler.getResponse().getStatus() == 200);
    Assert.assertTrue(tHandler.getThreadname().startsWith("xDispatcher"));
   
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.