Package org.asynchttpclient

Examples of org.asynchttpclient.Request

182
183
184
185
186
187
188
189
190
191
192
            builder.addBodyPart(new StringPart("Height", "shrimplike"));
            builder.addBodyPart(new StringPart("Hair", "ridiculous"));

            builder.addBodyPart(new ByteArrayPart("file4", expectedContents.getBytes(UTF_8), "text/plain", UTF_8, "bytearray.txt"));

            Request r = builder.build();

            Response res = c.executeRequest(r).get();

            assertEquals(res.getStatusCode(), 200);
View Full Code Here
22
23
24
25
26
27
28
29
30
31
32
public class ProxyUtilsTest {
    @Test(groups = "fast")
    public void testBasics() {
        // should avoid, there is no proxy (is null)
        Request req = new RequestBuilder("GET").setUrl("http://somewhere.com/foo").build();
        assertTrue(ProxyUtils.avoidProxy(null, req));

        // should avoid, it's in non-proxy hosts
        req = new RequestBuilder("GET").setUrl("http://somewhere.com/foo").build();
        ProxyServer proxyServer = new ProxyServer("foo", 1234);
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
        b.addResponseFilter(new ResponseFilter() {

            public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException {

                if (replay.getAndSet(false)) {
                    Request request = new RequestBuilder(ctx.getRequest()).addHeader("X-Replay", "true").build();
                    return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
                }
                return ctx;
            }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
        b.addResponseFilter(new ResponseFilter() {

            public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException {

                if (ctx.getResponseStatus() != null && ctx.getResponseStatus().getStatusCode() == 200 && replay.getAndSet(false)) {
                    Request request = new RequestBuilder(ctx.getRequest()).addHeader("X-Replay", "true").build();
                    return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
                }
                return ctx;
            }
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
            public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException {

                if (ctx.getResponseHeaders() != null && ctx.getResponseHeaders().getHeaders().getFirstValue("Ping").equals("Pong") && replay.getAndSet(false)) {

                    Request request = new RequestBuilder(ctx.getRequest()).addHeader("Ping", "Pong").build();
                    return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
                }
                return ctx;
            }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        AsyncHttpClientConfig config = new AsyncHttpClientConfig.Builder().setRealm(realmBuilder.build()).build();

        AsyncHttpClient client = getAsyncHttpClient(config);
        try {
            Request request = new RequestBuilder("GET").setUrl(getTargetUrl()).build();
            Future<Response> responseFuture = client.executeRequest(request);
            int status = responseFuture.get().getStatusCode();
            Assert.assertEquals(status, 200);
        } finally {
            client.close();
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
    @AfterMethod(alwaysRun = true)
    // FIXME not sure that's threadsafe
    public void clean() throws InterruptedException, Exception {
        AsyncHttpClient c = getAsyncHttpClient(null);
        try {
            Request deleteRequest = new RequestBuilder("DELETE").setUrl(getTargetUrl()).build();
            c.executeRequest(deleteRequest).get();
        } finally {
            c.close();
        }
    }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
    @Test(groups = { "standalone", "default_provider" })
    public void mkcolWebDavTest1() throws InterruptedException, IOException, ExecutionException {

        AsyncHttpClient c = getAsyncHttpClient(null);
        try {
            Request mkcolRequest = new RequestBuilder("MKCOL").setUrl(getTargetUrl()).build();
            Response response = c.executeRequest(mkcolRequest).get();

            assertEquals(response.getStatusCode(), 201);
        } finally {
            c.close();
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    @Test(groups = { "standalone", "default_provider" })
    public void mkcolWebDavTest2() throws InterruptedException, IOException, ExecutionException {

        AsyncHttpClient c = getAsyncHttpClient(null);
        try {
            Request mkcolRequest = new RequestBuilder("MKCOL").setUrl(getTargetUrl() + "/folder2").build();
            Response response = c.executeRequest(mkcolRequest).get();
            assertEquals(response.getStatusCode(), 409);
        } finally {
            c.close();
        }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
    @Test(groups = { "standalone", "default_provider" })
    public void basicPropFindWebDavTest() throws InterruptedException, IOException, ExecutionException {

        AsyncHttpClient c = getAsyncHttpClient(null);
        try {
            Request propFindRequest = new RequestBuilder("PROPFIND").setUrl(getTargetUrl()).build();
            Response response = c.executeRequest(propFindRequest).get();

            assertEquals(response.getStatusCode(), 404);
        } finally {
            c.close();
View Full Code Here
TOP

Related Classes of org.asynchttpclient.Request

  • org.asynchttpclient.async.AsyncProvidersBasicTest
  • org.asynchttpclient.async.ChunkingTest
  • org.asynchttpclient.async.FilterTest
  • org.asynchttpclient.async.Head302Test
  • org.asynchttpclient.async.MultipartUploadTest
  • org.asynchttpclient.async.MultipleHeaderTest
  • org.asynchttpclient.async.NTLMTest
  • org.asynchttpclient.async.PostRedirectGetTest
  • org.asynchttpclient.async.RedirectConnectionUsageTest
  • org.asynchttpclient.async.RemoteSiteTest
    • 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.