Package com.ning.http.client

Examples of com.ning.http.client.RequestBuilder.build()

277
278
279
280
281
282
283
284
285
286
287
            builder.setRealm(realm);
        }
        builder.setUrl(template.toString());
        builder.addHeader("Content-type", contentType);
        builder.setBody(body);
        return builder.build();
    }

    private Request req(String method, Uri template, int page) {
        RequestBuilder builder = new RequestBuilder(method);
        if (realm != null) {
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
        if (realm != null) {
            builder.setRealm(realm);
        }
        builder.addQueryParameter("page", Integer.toString(page));
        builder.setUrl(template.toString());
        return builder.build();
    }

    protected AsyncCompletionHandler<Void> handleStatus() {
        return new AsyncCompletionHandler<Void>() {
            @Override
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
                    AsyncHttpClientConnectionHandler.this.writeEntity(cr, adaptedOutputStream);
                }
            });
        }

        return builder.build();
    }

    private AsyncHttpClient openConnection(final ClientRequest request) {
        if (asyncHttpClient != null) {
            return asyncHttpClient;
View Full Code Here
210
211
212
213
214
215
216
217
218
219
220
        RequestBuilder builder = new RequestBuilder(request);
        if (request.getHeaders().get("Range") == null && byteTransferred.get() != 0) {
            builder.setHeader("Range", "bytes=" + byteTransferred.get() + "-");
        }
        return builder.build();
    }

    /**
     * Set a {@link ResumableListener}
     *
 
View Full Code Here
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
                        log.debug("Connecting to proxy {} for scheme {}", proxyServer, request.getUrl());
                        upgradeProtocol(ctx.getChannel().getPipeline(), request.getUrl());
                    } catch (Throwable ex) {
                        abort(future, ex);
                    }
                    nextRequest(builder.build(), future);
                    return;
                }

                boolean redirectEnabled = request.isRedirectEnabled() ? true : config.isRedirectEnabled();
                if (redirectEnabled && (statusCode == 302 || statusCode == 301)) {
View Full Code Here
414
415
416
417
418
419
420
421
422
423
424
                GrizzlyConnectorProvider.RequestCustomizer.class);
        if (requestCustomizer != null) {
            builder = requestCustomizer.customize(requestContext, builder);
        }

        return builder.build();
    }

    /**
     * Utility OutputStream implementation that can feed Grizzly chunk-encoded body generator.
     */
 
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
      builder.setUrl(uri.get());
      builder.setPerRequestConfig(prc);

      LOG.trace("Issuing a healthcheck ({}) for task {} with timeout {}s", uri.get(), task.getTaskId(), timeoutSeconds);

      http.prepareRequest(builder.build()).execute(handler);
    } catch (Throwable t) {
      LOG.debug("Exception while preparing healthcheck ({}) for task ({})", uri, task.getTaskId(), t);
      exceptionNotifier.notify(t);
      saveFailure(handler, String.format("Healthcheck failed due to exception: %s", t.getMessage()));
    }
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
        builder.setMethod(method);

        populateHeaders(builder, endpoint, exchange);
        populateBody(builder, endpoint, exchange);

        return builder.build();
    }

    protected String extractMethod(Exchange exchange) {
        // prefer method from header
        String method = exchange.getIn().getHeader(Exchange.HTTP_METHOD, String.class);
View Full Code Here
230
231
232
233
234
235
236
237
238
239
240
        if (entity != null) {
            builder = builder.setBody(entity);
        }

        com.ning.http.client.Request result = builder.build();
        writeOutBoundHeaders(requestContext.getHeaders(), result);

        return result;
    }
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
         builder.addHeader(HttpHeaders.USER_AGENT, USER_AGENT);
         for (Map<String, String> entry : request.getHeaders().entries()) {
            builder.addHeader(entry.getKey(), entry.getValue());
         }

         return builder.build();
      }

      void setPayload(RequestBuilder requestBuilder, Payload payload) {
         if (payload instanceof FilePayload) {
            requestBuilder.setBody(((FilePayload) payload).getRawContent());
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.