Package org.xlightweb

Examples of org.xlightweb.HttpRequestHeader$Parameter

80
81
82
83
84
85
86
87
88
89
90
      FileChannel fc = raf.getChannel();
 
      int size = (int) fc.size();
     
    FutureResponseHandler hdl = new FutureResponseHandler();
    BodyDataSink bodyDataSink = con.send(new HttpRequestHeader("POST", "/", "text/plain"), size, hdl);
   
    if (bodyDataSink.getFlushmode() != FlushMode.SYNC) {
      System.out.println("flush mode is not sync");
      Assert.fail("flush mode is not sync");
    }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
   
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
    con.setConnectionTimeoutMillis(1000);
   
    ResponseHandler respHdl = new ResponseHandler();
    HttpRequestHeader reqHdr = new HttpRequestHeader("POST", "/");

    BodyDataSink bodyDataSink = con.send(reqHdr, respHdl);
    bodyDataSink.write("er");
   
    QAUtil.sleep(1500);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
   
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
    con.setConnectionTimeoutMillis(1000);
   
    ResponseHandler2 respHdl = new ResponseHandler2();
    HttpRequestHeader reqHdr = new HttpRequestHeader("POST", "/");

    BodyDataSink bodyDataSink = con.send(reqHdr, respHdl);
    bodyDataSink.write("er");
   
    QAUtil.sleep(2000);
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
198
   
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
    con.setResponseTimeoutMillis(1000);
   
    ResponseHandler respHdl = new ResponseHandler();
    HttpRequestHeader reqHdr = new HttpRequestHeader("GET", "/");
    reqHdr.setHeader("sleep-time", Integer.toString(1000));

    con.send(reqHdr, respHdl);
   
    QAUtil.sleep(1500);
   
View Full Code Here
213
214
215
216
217
218
219
220
221
222
223
224
   
    HttpClientConnection con = new HttpClientConnection("localhost", server.getLocalPort());
    con.setResponseTimeoutMillis(1000);
   
    ResponseHandler2 respHdl = new ResponseHandler2();
    HttpRequestHeader reqHdr = new HttpRequestHeader("GET", "/");
    reqHdr.setHeader("sleep-time", Integer.toString(1000));

    con.send(reqHdr, respHdl);
   
    QAUtil.sleep(1500);
   
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
      HttpServer server = new HttpServer(reqHdl);
      server.start();
     
      HttpClient httpClient = new HttpClient();
      FutureResponseHandler respHdl = new FutureResponseHandler();
      BodyDataSink ds = httpClient.send(new HttpRequestHeader("POST", "http://localhost:" + server.getLocalPort() + "/?isWaitForBody=true", "text/plain;charset=UTF-8"), respHdl);
      ds.flush();
     
      QAUtil.sleep(1000);
      ds.write("1234567");
      ds.close();
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
        HttpServer server = new HttpServer(reqHdl);
        server.start();
       
        HttpClient httpClient = new HttpClient();
        FutureResponseHandler respHdl = new FutureResponseHandler();
        BodyDataSink ds = httpClient.send(new HttpRequestHeader("POST", "http://localhost:" + server.getLocalPort() + "/", "text/plain;charset=UTF-8"), respHdl);
        ds.flush();
       
        QAUtil.sleep(1000);
        ds.write("1234567");
        ds.close();
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
        HttpServer server = new HttpServer(reqHdl);
        server.start();
       
        HttpClient httpClient = new HttpClient();
        FutureResponseHandler respHdl = new FutureResponseHandler();
        BodyDataSink ds = httpClient.send(new HttpRequestHeader("POST", "http://localhost:" + server.getLocalPort() + "/", "text/plain;charset=UTF-8"), respHdl);
        ds.flush();
       
        QAUtil.sleep(1000);

        ds.close();
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
                    exchange.send(response);
                } else {
                   
                    // switch to GET?
                    if ((response.getStatus() == 303) || ((response.getStatus() == 302)) && httpClient.isTreat302RedirectAs303()){
                        requestHeader = new HttpRequestHeader("GET", newLocation.toString());
                       
                    } else {
                        // .. and update the stored request
                        requestHeader.setRequestUrl(newLocation);
                    }
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
      public void onException(IOException ioe) {
      }
    };


    BodyDataSink outChannel = con.send(new HttpRequestHeader("POST", "/"), 100, resHdl);

    outChannel.write(QAUtil.generateByteArray(100));
   
    outChannel.close();
   
View Full Code Here
TOP

Related Classes of org.xlightweb.HttpRequestHeader$Parameter

  • com.alibaba.citrus.util.internal.ToStringBuilder
  • com.alibaba.citrus.util.ToStringBuilder
  • it.eng.spagobi.tools.dataset.common.datastore.IField
  • net.oauth.v2.example.provider.servlets.AuthorizationServlet2
  • org.andromda.metafacades.emf.uml2.OperationFacadeLogicImpl
  • org.andromda.metafacades.emf.uml2.UmlUtilities
  • org.apache.commons.lang.builder.HashCodeBuilder
  • org.xlightweb.BodyDataSinkCloseTest
  • org.xlightweb.ChannelStreamingTest
  • org.xlightweb.client.HttpClientConnectionPoolTest
    • Copyright © 2018 www.massapicom. 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.