- * AsyncHandler ah = new AsyncHandler() {....};
- * AsyncHttpClient client = new AsyncHttpClient();
- * client.prepareGet("http://.../").execute(ah);
- * client.prepareGet("http://.../").execute(ah);
- * - * The code above will block until the response is fully received. To execute asynchronous HTTP request, you - * create an {@link AsyncHandler} or its abstract implementation, {@link AsyncCompletionHandler} - * - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet("http://www.ning.com/").execute(); - *
- * You can also have more control about the how the response is asynchronously processed by using a {@link AsyncHandler} - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet("http://www.ning.com/").execute(new AsyncCompletionHandler () { - * - * @Override - * public Response onCompleted(Response response) throws IOException { - * // Do something - * return response; - * } - * - * @Override - * public void onThrowable(Throwable t) { - * } - * }); - * Response response = f.get(); - * - * // We are just interested to retrieve the status code. - * Future f = c.prepareGet("http://www.ning.com/").execute(new AsyncCompletionHandler () { - * - * @Override - * public Integer onCompleted(Response response) throws IOException { - * // Do something - * return response.getStatusCode(); - * } - * - * @Override - * public void onThrowable(Throwable t) { - * } - * }); - * Integer statusCode = f.get(); - *
- * This class can also be used without the need of {@link AsyncHandler} - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet("http://www.ning.com/").execute(new AsyncHandler () { - * private StringBuilder builder = new StringBuilder(); - * - * @Override - * public STATE onStatusReceived(HttpResponseStatus s) throws Exception { - * // return STATE.CONTINUE or STATE.ABORT - * return STATE.CONTINUE - * } - * - * @Override - * public STATE onHeadersReceived(HttpResponseHeaders bodyPart) throws Exception { - * // return STATE.CONTINUE or STATE.ABORT - * return STATE.CONTINUE - * - * } - * @Override - * - * public STATE onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception { - * builder.append(new String(bodyPart)); - * // return STATE.CONTINUE or STATE.ABORT - * return STATE.CONTINUE - * } - * - * @Override - * public String onCompleted() throws Exception { - * // Will be invoked once the response has been fully read or a ResponseComplete exception - * // has been thrown. - * return builder.toString(); - * } - * - * @Override - * public void onThrowable(Throwable t) { - * } - * }); - * - * String bodyResponse = f.get(); - *
- * - * Finally, you can configure the AsyncHttpClient using an {@link AsyncHttpClientConfig} instance - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet(TARGET_URL).execute(); - * Response r = f.get(); - *
- * - * An instance of this class will cache every HTTP 1.1 connections and close them when the {@link AsyncHttpClientConfig#getReadTimeout()} - * expires. This object can hold many persistent connections to different host. - */ -public interface AsyncHttpClient extends Closeable { - - /** - * Return the asynchronous {@link AsyncHttpProvider} - * - * @return an {@link AsyncHttpProvider} - */ - AsyncHttpProvider getProvider(); - - /** - * Close the underlying connections. - */ - void close(); - - /** - * Asynchronous close the {@link AsyncHttpProvider} by spawning a thread and avoid blocking. - */ - void closeAsynchronously(); - - /** - * Return true if closed - * - * @return true if closed - */ - boolean isClosed(); - - /** - * Return the {@link AsyncHttpClientConfig} - * - * @return {@link AsyncHttpClientConfig} - */ - AsyncHttpClientConfig getConfig(); - - /** - * Set default signature calculator to use for requests build by this client instance - */ - AsyncHttpClient setSignatureCalculator(SignatureCalculator signatureCalculator); - - /** - * Prepare an HTTP client GET request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareGet(String url); - - /** - * Prepare an HTTP client CONNECT request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareConnect(String url); - - /** - * Prepare an HTTP client OPTIONS request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareOptions(String url); - - /** - * Prepare an HTTP client HEAD request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareHead(String url); - - /** - * Prepare an HTTP client POST request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder preparePost(String url); - - /** - * Prepare an HTTP client PUT request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder preparePut(String url); - - /** - * Prepare an HTTP client DELETE request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareDelete(String url); - - /** - * Prepare an HTTP client PATCH request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder preparePatch(String url); - - /** - * Prepare an HTTP client TRACE request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareTrace(String url); - - /** - * Construct a {@link RequestBuilder} using a {@link Request} - * - * @param request a {@link Request} - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareRequest(Request request); - - /** - * Execute an HTTP request. - * - * @param request {@link Request} - * @param handler an instance of {@link AsyncHandler} - * @param- * AsyncHttpClient c = new AsyncHttpClient(new AsyncHttpClientConfig.Builder().setRequestTimeoutInMs(...).build()); - * Futuref = c.prepareGet(TARGET_URL).execute(); - * Response r = f.get(); - *
null
- */
- public ExecutorService executorService() {
- return applicationThreadPool;
- }
-
- /**
- * An instance of {@link ProxyServer} used by an {@link AsyncHttpClient}
- *
- * @return instance of {@link ProxyServer}
- */
- public ProxyServerSelector getProxyServerSelector() {
- return proxyServerSelector;
- }
-
- /**
- * Return an instance of {@link SSLContext} used for SSL connection.
- *
- * @return an instance of {@link SSLContext} used for SSL connection.
- */
- public SSLContext getSSLContext() {
- return sslContext;
- }
-
- /**
- * Return the {@link AsyncHttpProviderConfig}
- *
- * @return the {@link AsyncHttpProviderConfig}
- */
- public AsyncHttpProviderConfig getAsyncHttpProviderConfig() {
- return providerConfig;
- }
-
- /**
- * Return the current {@link Realm}}
- *
- * @return the current {@link Realm}}
- */
- public Realm getRealm() {
- return realm;
- }
-
- /**
- * @return true if {@link RequestFilter}s have been defined.
- *
- * @since 2.0.0
- */
- public boolean hasRequestFilters() {
- return !requestFilters.isEmpty();
- }
-
- /**
- * Return the list of {@link RequestFilter}
- *
- * @return Unmodifiable list of {@link ResponseFilter}
- */
- public Listtrue if {@link ResponseFilter}s have been defined.
- * @since 2.0.0
- */
- public boolean hasResponseFilters() {
- return !responseFilters.isEmpty();
- }
-
- /**
- * Return the list of {@link ResponseFilter}
- *
- * @return Unmodifiable list of {@link ResponseFilter}
- */
- public Listtrue if both the application and reaper thread pools
- * haven't yet been shutdown.
- * @since 1.7.21
- */
- public boolean isValid() {
- boolean atpRunning = true;
- try {
- atpRunning = applicationThreadPool.isShutdown();
- } catch (Exception ignore) {
- // isShutdown() will thrown an exception in an EE7 environment
- // when using a ManagedExecutorService.
- // When this is the case, we assume it's running.
- }
- return atpRunning;
- }
-
- /**
- * @return number to multiply by availableProcessors() that will determine # of NioWorkers to use
- */
- public int getIoThreadMultiplier() {
- return ioThreadMultiplier;
- }
-
- /**
- * - * In the case of a POST/Redirect/Get scenario where the server uses a 302 - * for the redirect, should AHC respond to the redirect with a GET or - * whatever the original method was. Unless configured otherwise, - * for a 302, AHC, will use a GET for this case. - *
- * - * @returntrue if string 302 handling is to be used,
- * otherwise false.
- *
- * @since 1.7.2
- */
- public boolean isStrict302Handling() {
- return strict302Handling;
- }
-
- /**
- * @returntrue if AHC should use relative URIs instead of absolute ones when talking with a SSL proxy
- * or WebSocket proxy, otherwise false.
- *
- * @since 1.8.13
- */
- public boolean isUseRelativeURIsWithConnectProxies() {
- return useRelativeURIsWithConnectProxies;
- }
-
- /**
- * Return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in the pool, or -1 to keep connection while possible.
- *
- * @return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in the pool, or -1 to keep connection while possible.
- */
- public int getConnectionTTL() {
- return connectionTTL;
- }
-
- public boolean isAcceptAnyCertificate() {
- return acceptAnyCertificate;
- }
-
- /**
- * since 1.9.0
- */
- public String[] getEnabledProtocols() {
- return enabledProtocols;
- }
-
- /**
- * since 1.9.0
- */
- public String[] getEnabledCipherSuites() {
- return enabledCipherSuites;
- }
-
- /**
- * since 1.9.13
- */
- public Integer getSslSessionCacheSize() {
- return sslSessionCacheSize;
- }
-
- /**
- * since 1.9.13
- */
- public Integer getSslSessionTimeout() {
- return sslSessionTimeout;
- }
-
- /**
- * Builder for an {@link AsyncHttpClient}
- */
- public static class Builder {
- private int connectTimeout = defaultConnectTimeout();
- private int maxConnections = defaultMaxConnections();
- private int maxConnectionsPerHost = defaultMaxConnectionsPerHost();
- private int requestTimeout = defaultRequestTimeout();
- private int readTimeout = defaultReadTimeout();
- private int webSocketTimeout = defaultWebSocketTimeout();
- private boolean allowPoolingConnections = defaultAllowPoolingConnections();
- private boolean allowPoolingSslConnections = defaultAllowPoolingSslConnections();
- private int pooledConnectionIdleTimeout = defaultPooledConnectionIdleTimeout();
- private int connectionTTL = defaultConnectionTTL();
- private SSLContext sslContext;
- private boolean acceptAnyCertificate = defaultAcceptAnyCertificate();
- private boolean followRedirect = defaultFollowRedirect();
- private int maxRedirects = defaultMaxRedirects();
- private boolean strict302Handling = defaultStrict302Handling();
- private ProxyServerSelector proxyServerSelector = null;
- private boolean useProxySelector = defaultUseProxySelector();
- private boolean useProxyProperties = defaultUseProxyProperties();
- private boolean useRelativeURIsWithConnectProxies = defaultUseRelativeURIsWithConnectProxies();
- private boolean compressionEnforced = defaultCompressionEnforced();
- private String userAgent = defaultUserAgent();
- private ExecutorService applicationThreadPool;
- private Realm realm;
- private final Listtrue but {@link #setProxyServer(ProxyServer)}
- * was used to explicitly set a proxy server, the latter is preferred.
- *
- * See http://docs.oracle.com/javase/7/docs/api/java/net/ProxySelector.html
- */
- public Builder setUseProxySelector(boolean useProxySelector) {
- this.useProxySelector = useProxySelector;
- return this;
- }
-
- /**
- * Sets whether AHC should use the default http.proxy* system properties
- * to obtain proxy information. This differs from {@link #setUseProxySelector(boolean)}
- * in that AsyncHttpClient will use its own logic to handle the system properties,
- * potentially supporting other protocols that the the JDK ProxySelector doesn't.
- *
- * If useProxyProperties is set to true but {@link #setUseProxySelector(boolean)}
- * was also set to true, the latter is preferred.
- *
- * See http://download.oracle.com/javase/1.4.2/docs/guide/net/properties.html
- */
- public Builder setUseProxyProperties(boolean useProxyProperties) {
- this.useProxyProperties = useProxyProperties;
- return this;
- }
-
- public Builder setIOThreadMultiplier(int multiplier) {
- this.ioThreadMultiplier = multiplier;
- return this;
- }
-
- /**
- * Configures this AHC instance to be strict in it's handling of 302 redirects
- * in a POST/Redirect/GET situation.
- *
- * @param strict302Handling strict handling
- *
- * @return this
- *
- * @since 1.7.2
- */
- public Builder setStrict302Handling(final boolean strict302Handling) {
- this.strict302Handling = strict302Handling;
- return this;
- }
-
- /**
- * Set the maximum time in millisecond connection can be added to the pool for further reuse
- *
- * @param connectionTTL the maximum time in millisecond connection can be added to the pool for further reuse
- * @return a {@link Builder}
- */
- public Builder setConnectionTTL(int connectionTTL) {
- this.connectionTTL = connectionTTL;
- return this;
- }
-
- /**
- * Configures this AHC instance to use relative URIs instead of absolute ones when talking with a SSL or WebSocket proxy.
- *
- * @param useRelativeURIsWithConnectProxies
- * @return this
- *
- * @since 1.7.2
- */
- public Builder setUseRelativeURIsWithConnectProxies(boolean useRelativeURIsWithConnectProxies) {
- this.useRelativeURIsWithConnectProxies = useRelativeURIsWithConnectProxies;
- return this;
- }
-
- /**
- * Enables SPDY support. Note that doing so, will currently disable WebSocket support
- * for this client instance. If not explicitly enabled, spdy will not be used.
- *
- * @param spdyEnabled configures spdy support.
- *
- * @return this
- *
- * @since 2.0
- */
- public Builder setSpdyEnabled(boolean spdyEnabled) {
- this.spdyEnabled = spdyEnabled;
- return this;
- }
-
- /**
- * Configures the initial window size for the SPDY session.
- *
- * @param spdyInitialWindowSize the initial window size.
- *
- * @return this
- *
- * @since 2.0
- */
- public Builder setSpdyInitialWindowSize(int spdyInitialWindowSize) {
- this.spdyInitialWindowSize = spdyInitialWindowSize;
- return this;
- }
-
- /**
- * Configures the maximum number of concurrent streams over a single
- * SPDY session.
- *
- * @param spdyMaxConcurrentStreams the maximum number of concurrent
- * streams over a single SPDY session.
- *
- * @return this
- *
- * @since 2.0
- */
- public Builder setSpdyMaxConcurrentStreams(int spdyMaxConcurrentStreams) {
- this.spdyMaxConcurrentStreams = spdyMaxConcurrentStreams;
- return this;
- }
-
- public Builder setAcceptAnyCertificate(boolean acceptAnyCertificate) {
- this.acceptAnyCertificate = acceptAnyCertificate;
- return this;
- }
-
- public Builder setEnabledProtocols(String[] enabledProtocols) {
- this.enabledProtocols = enabledProtocols;
- return this;
- }
-
- public Builder setEnabledCipherSuites(String[] enabledCipherSuites) {
- this.enabledCipherSuites = enabledCipherSuites;
- return this;
- }
-
- public Builder setSslSessionCacheSize(Integer sslSessionCacheSize) {
- this.sslSessionCacheSize = sslSessionCacheSize;
- return this;
- }
-
- public Builder setSslSessionTimeout(Integer sslSessionTimeout) {
- this.sslSessionTimeout = sslSessionTimeout;
- return this;
- }
-
- /**
- * Create a config builder with values taken from the given prototype configuration.
- *
- * @param prototype the configuration to use as a prototype.
- */
- public Builder(AsyncHttpClientConfig prototype) {
- allowPoolingConnections = prototype.isAllowPoolingConnections();
- providerConfig = prototype.getAsyncHttpProviderConfig();
- connectTimeout = prototype.getConnectTimeout();
- pooledConnectionIdleTimeout = prototype.getPooledConnectionIdleTimeout();
- readTimeout = prototype.getReadTimeout();
- maxConnectionsPerHost = prototype.getMaxConnectionsPerHost();
- connectionTTL = prototype.getConnectionTTL();
- maxRedirects = prototype.getMaxRedirects();
- maxConnections = prototype.getMaxConnections();
- proxyServerSelector = prototype.getProxyServerSelector();
- realm = prototype.getRealm();
- requestTimeout = prototype.getRequestTimeout();
- sslContext = prototype.getSSLContext();
- userAgent = prototype.getUserAgent();
- followRedirect = prototype.isFollowRedirect();
- compressionEnforced = prototype.isCompressionEnforced();
- applicationThreadPool = prototype.executorService();
-
- requestFilters.clear();
- responseFilters.clear();
- ioExceptionFilters.clear();
-
- requestFilters.addAll(prototype.getRequestFilters());
- responseFilters.addAll(prototype.getResponseFilters());
- ioExceptionFilters.addAll(prototype.getIOExceptionFilters());
-
- disableUrlEncodingForBoundRequests = prototype.isDisableUrlEncodingForBoundRequests();
- ioThreadMultiplier = prototype.getIoThreadMultiplier();
- maxRequestRetry = prototype.getMaxRequestRetry();
- allowPoolingSslConnections = prototype.isAllowPoolingConnections();
- strict302Handling = prototype.isStrict302Handling();
- acceptAnyCertificate = prototype.acceptAnyCertificate;
- enabledProtocols = prototype.enabledProtocols;
- enabledCipherSuites = prototype.enabledCipherSuites;
- sslSessionCacheSize = prototype.sslSessionCacheSize;
- sslSessionTimeout = prototype.sslSessionTimeout;
-
- spdyEnabled = prototype.isSpdyEnabled();
- spdyInitialWindowSize = prototype.getSpdyInitialWindowSize();
- spdyMaxConcurrentStreams = prototype.getSpdyMaxConcurrentStreams();
- }
-
- /**
- * Build an {@link AsyncHttpClientConfig}
- *
- * @return an {@link AsyncHttpClientConfig}
- */
- public AsyncHttpClientConfig build() {
-
- if (proxyServerSelector == null && useProxySelector)
- proxyServerSelector = ProxyUtils.getJdkDefaultProxyServerSelector();
-
- if (proxyServerSelector == null && useProxyProperties)
- proxyServerSelector = ProxyUtils.createProxyServerSelector(System.getProperties());
-
- if (proxyServerSelector == null)
- proxyServerSelector = ProxyServerSelector.NO_PROXY_SELECTOR;
-
- return new AsyncHttpClientConfig(connectTimeout,//
- maxConnections,//
- maxConnectionsPerHost,//
- requestTimeout,//
- readTimeout,//
- webSocketTimeout,//
- allowPoolingConnections,//
- allowPoolingSslConnections,//
- pooledConnectionIdleTimeout,//
- connectionTTL,//
- sslContext, //
- acceptAnyCertificate, //
- followRedirect, //
- maxRedirects, //
- strict302Handling, //
- applicationThreadPool, //
- proxyServerSelector, //
- useRelativeURIsWithConnectProxies, //
- compressionEnforced, //
- userAgent,//
- realm,//
- requestFilters, //
- responseFilters,//
- ioExceptionFilters,//
- maxRequestRetry, //
- disableUrlEncodingForBoundRequests, //
- ioThreadMultiplier, //
- enabledProtocols, //
- enabledCipherSuites, //
- sslSessionCacheSize, //
- sslSessionTimeout, //
- providerConfig, //
- spdyEnabled, //
- spdyInitialWindowSize, //
- spdyMaxConcurrentStreams);
- }
- }
-}
diff --git a/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigBean.java b/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigBean.java
deleted file mode 100644
index 8d74535c31..0000000000
--- a/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigBean.java
+++ /dev/null
@@ -1,238 +0,0 @@
-/*
- * Copyright (c) 2010-2012 Sonatype, Inc. All rights reserved.
- *
- * This program is licensed to you under the Apache License Version 2.0,
- * and you may not use this file except in compliance with the Apache License Version 2.0.
- * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the Apache License Version 2.0 is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
- */
-package org.asynchttpclient;
-
-import static org.asynchttpclient.AsyncHttpClientConfigDefaults.*;
-
-import org.asynchttpclient.filter.IOExceptionFilter;
-import org.asynchttpclient.filter.RequestFilter;
-import org.asynchttpclient.filter.ResponseFilter;
-import org.asynchttpclient.util.ProxyUtils;
-
-import javax.net.ssl.SSLContext;
-
-import java.util.LinkedList;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ThreadFactory;
-
-/**
- * Simple JavaBean version of {@link AsyncHttpClientConfig}
- */
-public class AsyncHttpClientConfigBean extends AsyncHttpClientConfig {
-
- public AsyncHttpClientConfigBean() {
- configureExecutors();
- configureDefaults();
- configureFilters();
- }
-
- void configureFilters() {
- requestFilters = new LinkedList<>();
- responseFilters = new LinkedList<>();
- ioExceptionFilters = new LinkedList<>();
- }
-
- void configureDefaults() {
- maxConnections = defaultMaxConnections();
- maxConnectionsPerHost = defaultMaxConnectionsPerHost();
- connectTimeout = defaultConnectTimeout();
- webSocketTimeout = defaultWebSocketTimeout();
- pooledConnectionIdleTimeout = defaultPooledConnectionIdleTimeout();
- readTimeout = defaultReadTimeout();
- requestTimeout = defaultRequestTimeout();
- connectionTTL = defaultConnectionTTL();
- followRedirect = defaultFollowRedirect();
- maxRedirects = defaultMaxRedirects();
- compressionEnforced = defaultCompressionEnforced();
- userAgent = defaultUserAgent();
- allowPoolingConnections = defaultAllowPoolingConnections();
- useRelativeURIsWithConnectProxies = defaultUseRelativeURIsWithConnectProxies();
- maxRequestRetry = defaultMaxRequestRetry();
- ioThreadMultiplier = defaultIoThreadMultiplier();
- allowPoolingSslConnections = defaultAllowPoolingSslConnections();
- disableUrlEncodingForBoundRequests = defaultDisableUrlEncodingForBoundRequests();
- strict302Handling = defaultStrict302Handling();
- acceptAnyCertificate = defaultAcceptAnyCertificate();
- sslSessionCacheSize = defaultSslSessionCacheSize();
- sslSessionTimeout = defaultSslSessionTimeout();
-
- if (defaultUseProxySelector()) {
- proxyServerSelector = ProxyUtils.getJdkDefaultProxyServerSelector();
- } else if (defaultUseProxyProperties()) {
- proxyServerSelector = ProxyUtils.createProxyServerSelector(System.getProperties());
- }
- // AHC 2
- spdyEnabled = defaultSpdyEnabled();
- spdyInitialWindowSize = defaultSpdyInitialWindowSize();
- spdyMaxConcurrentStreams = defaultSpdyMaxConcurrentStreams();
- }
-
- void configureExecutors() {
- applicationThreadPool = Executors.newCachedThreadPool(new ThreadFactory() {
- public Thread newThread(Runnable r) {
- Thread t = new Thread(r, "AsyncHttpClient-Callback");
- t.setDaemon(true);
- return t;
- }
- });
- }
-
- public AsyncHttpClientConfigBean setMaxTotalConnections(int maxConnections) {
- this.maxConnections = maxConnections;
- return this;
- }
-
- public AsyncHttpClientConfigBean setMaxConnectionsPerHost(int maxConnectionsPerHost) {
- this.maxConnectionsPerHost = maxConnectionsPerHost;
- return this;
- }
-
- public AsyncHttpClientConfigBean setConnectTimeout(int connectTimeout) {
- this.connectTimeout = connectTimeout;
- return this;
- }
-
- public AsyncHttpClientConfigBean setConnectionTTL(int connectionTTL) {
- this.connectionTTL = connectionTTL;
- return this;
- }
-
- public AsyncHttpClientConfigBean setPooledConnectionIdleTimeout(int pooledConnectionIdleTimeout) {
- this.pooledConnectionIdleTimeout = pooledConnectionIdleTimeout;
- return this;
- }
-
- public AsyncHttpClientConfigBean setReadTimeout(int readTimeout) {
- this.readTimeout = readTimeout;
- return this;
- }
-
- public AsyncHttpClientConfigBean setRequestTimeout(int requestTimeout) {
- this.requestTimeout = requestTimeout;
- return this;
- }
-
- public AsyncHttpClientConfigBean setFollowRedirect(boolean followRedirect) {
- this.followRedirect = followRedirect;
- return this;
- }
-
- public AsyncHttpClientConfigBean setMaxRedirects(int maxRedirects) {
- this.maxRedirects = maxRedirects;
- return this;
- }
-
- public AsyncHttpClientConfigBean setStrict302Handling(boolean strict302Handling) {
- this.strict302Handling = strict302Handling;
- return this;
- }
-
- public AsyncHttpClientConfigBean setCompressionEnforced(boolean compressionEnforced) {
- this.compressionEnforced = compressionEnforced;
- return this;
- }
-
- public AsyncHttpClientConfigBean setUserAgent(String userAgent) {
- this.userAgent = userAgent;
- return this;
- }
-
- public AsyncHttpClientConfigBean setAllowPoolingConnections(boolean allowPoolingConnections) {
- this.allowPoolingConnections = allowPoolingConnections;
- return this;
- }
-
- public AsyncHttpClientConfigBean setApplicationThreadPool(ExecutorService applicationThreadPool) {
- if (this.applicationThreadPool != null) {
- this.applicationThreadPool.shutdownNow();
- }
- this.applicationThreadPool = applicationThreadPool;
- return this;
- }
-
- public AsyncHttpClientConfigBean setProxyServer(ProxyServer proxyServer) {
- this.proxyServerSelector = ProxyUtils.createProxyServerSelector(proxyServer);
- return this;
- }
-
- public AsyncHttpClientConfigBean setProxyServerSelector(ProxyServerSelector proxyServerSelector) {
- this.proxyServerSelector = proxyServerSelector;
- return this;
- }
-
- public AsyncHttpClientConfigBean setSslContext(SSLContext sslContext) {
- this.sslContext = sslContext;
- return this;
- }
-
- public AsyncHttpClientConfigBean setProviderConfig(AsyncHttpProviderConfig providerConfig) {
- this.providerConfig = providerConfig;
- return this;
- }
-
- public AsyncHttpClientConfigBean setRealm(Realm realm) {
- this.realm = realm;
- return this;
- }
-
- public AsyncHttpClientConfigBean addRequestFilter(RequestFilter requestFilter) {
- requestFilters.add(requestFilter);
- return this;
- }
-
- public AsyncHttpClientConfigBean addResponseFilters(ResponseFilter responseFilter) {
- responseFilters.add(responseFilter);
- return this;
- }
-
- public AsyncHttpClientConfigBean addIoExceptionFilters(IOExceptionFilter ioExceptionFilter) {
- ioExceptionFilters.add(ioExceptionFilter);
- return this;
- }
-
- public AsyncHttpClientConfigBean setMaxRequestRetry(int maxRequestRetry) {
- this.maxRequestRetry = maxRequestRetry;
- return this;
- }
-
- public AsyncHttpClientConfigBean setAllowPoolingSslConnections(boolean allowPoolingSslConnections) {
- this.allowPoolingSslConnections = allowPoolingSslConnections;
- return this;
- }
-
- public AsyncHttpClientConfigBean setDisableUrlEncodingForBoundRequests(boolean disableUrlEncodingForBoundRequests) {
- this.disableUrlEncodingForBoundRequests = disableUrlEncodingForBoundRequests;
- return this;
- }
-
- public AsyncHttpClientConfigBean setIoThreadMultiplier(int ioThreadMultiplier) {
- this.ioThreadMultiplier = ioThreadMultiplier;
- return this;
- }
-
- public AsyncHttpClientConfigBean setAcceptAnyCertificate(boolean acceptAnyCertificate) {
- this.acceptAnyCertificate = acceptAnyCertificate;
- return this;
- }
-
- public AsyncHttpClientConfigBean setSslSessionCacheSize(Integer sslSessionCacheSize) {
- this.sslSessionCacheSize = sslSessionCacheSize;
- return this;
- }
-
- public AsyncHttpClientConfigBean setSslSessionTimeout(Integer sslSessionTimeout) {
- this.sslSessionTimeout = sslSessionTimeout;
- return this;
- }
-}
diff --git a/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigDefaults.java b/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigDefaults.java
deleted file mode 100644
index 4760d8eebd..0000000000
--- a/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigDefaults.java
+++ /dev/null
@@ -1,131 +0,0 @@
-/*
- * Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
- *
- * This program is licensed to you under the Apache License Version 2.0,
- * and you may not use this file except in compliance with the Apache License Version 2.0.
- * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the Apache License Version 2.0 is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
- */
-package org.asynchttpclient;
-
-import org.asynchttpclient.util.AsyncPropertiesHelper;
-
-public final class AsyncHttpClientConfigDefaults {
-
- private AsyncHttpClientConfigDefaults() {
- }
-
- public static final String ASYNC_CLIENT = AsyncHttpClientConfig.class.getName() + ".";
-
- public static int defaultMaxConnections() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "maxConnections");
- }
-
- public static int defaultMaxConnectionsPerHost() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "maxConnectionsPerHost");
- }
-
- public static int defaultConnectTimeout() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "connectTimeout");
- }
-
- public static int defaultPooledConnectionIdleTimeout() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "pooledConnectionIdleTimeout");
- }
-
- public static int defaultReadTimeout() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "readTimeout");
- }
-
- public static int defaultRequestTimeout() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "requestTimeout");
- }
-
- public static int defaultWebSocketTimeout() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "webSocketTimeout");
- }
-
- public static int defaultConnectionTTL() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "connectionTTL");
- }
-
- public static boolean defaultFollowRedirect() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "followRedirect");
- }
-
- public static int defaultMaxRedirects() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "maxRedirects");
- }
-
- public static boolean defaultCompressionEnforced() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "compressionEnforced");
- }
-
- public static String defaultUserAgent() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getString(ASYNC_CLIENT + "userAgent");
- }
-
- public static int defaultIoThreadMultiplier() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "ioThreadMultiplier");
- }
-
- public static boolean defaultUseProxySelector() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "useProxySelector");
- }
-
- public static boolean defaultUseProxyProperties() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "useProxyProperties");
- }
-
- public static boolean defaultStrict302Handling() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "strict302Handling");
- }
-
- public static boolean defaultAllowPoolingConnections() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "allowPoolingConnections");
- }
-
- public static boolean defaultUseRelativeURIsWithConnectProxies() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "useRelativeURIsWithConnectProxies");
- }
-
- public static int defaultMaxRequestRetry() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "maxRequestRetry");
- }
-
- public static boolean defaultAllowPoolingSslConnections() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "allowPoolingSslConnections");
- }
-
- public static boolean defaultDisableUrlEncodingForBoundRequests() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "disableUrlEncodingForBoundRequests");
- }
-
- public static boolean defaultSpdyEnabled() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "spdyEnabled");
- }
-
- public static int defaultSpdyInitialWindowSize() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "spdyInitialWindowSize");
- }
-
- public static int defaultSpdyMaxConcurrentStreams() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT + "spdyMaxConcurrentStreams");
- }
-
- public static boolean defaultAcceptAnyCertificate() {
- return AsyncPropertiesHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT + "acceptAnyCertificate");
- }
-
- public static Integer defaultSslSessionCacheSize() {
- return Integer.getInteger(ASYNC_CLIENT + "sslSessionCacheSize");
- }
-
- public static Integer defaultSslSessionTimeout() {
- return Integer.getInteger(ASYNC_CLIENT + "sslSessionTimeout");
- }
-}
diff --git a/api/src/main/java/org/asynchttpclient/AsyncHttpProvider.java b/api/src/main/java/org/asynchttpclient/AsyncHttpProvider.java
deleted file mode 100644
index 0bb74e800c..0000000000
--- a/api/src/main/java/org/asynchttpclient/AsyncHttpProvider.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/*
- * Copyright 2010 Ning, Inc.
- *
- * Ning licenses this file to you under the Apache License, version 2.0
- * (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at:
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations
- * under the License.
- */
-package org.asynchttpclient;
-
-import java.io.Closeable;
-
-/**
- * Interface to be used when implementing custom asynchronous I/O HTTP client.
- */
-public interface AsyncHttpProvider extends Closeable {
-
- /**
- * Execute the request and invoke the {@link AsyncHandler} when the response arrive.
- *
- * @param handler an instance of {@link AsyncHandler}
- * @return a {@link ListenableFuture} of Type T.
- */
- client.prepareGet("http://foo.com/aResource").execute().get()
- * would not work for you, since a potentially large response body is about to
- * be GETted, but you need headers first, or you don't know yet (depending on
- * some logic, maybe coming from headers) where to save the body, or you just
- * want to leave body stream to some other component to consume it.
- *
- * All these above means that this AsyncHandler needs a bit of different
- * handling than "recommended" way. Some examples:
- *
- *
- * FileOutputStream fos = ...
- * BodyDeferringAsyncHandler bdah = new BodyDeferringAsyncHandler(fos);
- * // client executes async
- * Future<Response> fr = client.prepareGet("http://foo.com/aresource").execute(
- * bdah);
- * // main thread will block here until headers are available
- * Response response = bdah.getResponse();
- * // you can continue examine headers while actual body download happens
- * // in separate thread
- * // ...
- * // finally "join" the download
- * fr.get();
- *
- *
- *
- * PipedOutputStream pout = new PipedOutputStream();
- * BodyDeferringAsyncHandler bdah = new BodyDeferringAsyncHandler(pout);
- * // client executes async
- * Future<Response> fr = client.prepareGet("http://foo.com/aresource").execute(bdah);
- * // main thread will block here until headers are available
- * Response response = bdah.getResponse();
- * if (response.getStatusCode() == 200) {
- * InputStream pin = new BodyDeferringInputStream(fr,new PipedInputStream(pout));
- * // consume InputStream
- * ...
- * } else {
- * // handle unexpected response status code
- * ...
- * }
- *
- */
-public class BodyDeferringAsyncHandler implements AsyncHandlernull
- * in case of some errors.
- *
- * @return a {@link Response}
- * @throws InterruptedException
- */
- public Response getResponse() throws InterruptedException, IOException {
- // block here as long as headers arrive
- headersArrived.await();
-
- try {
- semaphore.acquire();
- if (throwable != null) {
- IOException ioe = new IOException(throwable.getMessage());
- ioe.initCause(throwable);
- throw ioe;
- } else {
- return response;
- }
- } finally {
- semaphore.release();
- }
- }
-
- // ==
-
- /**
- * A simple helper class that is used to perform automatic "join" for async
- * download and the error checking of the Future of the request.
- */
- public static class BodyDeferringInputStream extends FilterInputStream {
- private final Futurenull. See
- * {@link BodyDeferringAsyncHandler#getResponse()} method for details.
- *
- * @return a {@link Response}
- * @throws InterruptedException
- */
- public Response getAsapResponse() throws InterruptedException, IOException {
- return bdah.getResponse();
- }
-
- /**
- * Delegates to Future#get() method. Will block
- * as long as complete response arrives.
- *
- * @return a {@link Response}
- * @throws InterruptedException
- * @throws ExecutionException
- */
- public Response getLastResponse() throws InterruptedException, ExecutionException {
- return future.get();
- }
- }
-}
\ No newline at end of file
diff --git a/api/src/main/java/org/asynchttpclient/BoundRequestBuilder.java b/api/src/main/java/org/asynchttpclient/BoundRequestBuilder.java
deleted file mode 100644
index 028ce2a8c7..0000000000
--- a/api/src/main/java/org/asynchttpclient/BoundRequestBuilder.java
+++ /dev/null
@@ -1,133 +0,0 @@
-/*
- * Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
- *
- * This program is licensed to you under the Apache License Version 2.0,
- * and you may not use this file except in compliance with the Apache License Version 2.0.
- * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the Apache License Version 2.0 is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
- */
-package org.asynchttpclient;
-
-import org.asynchttpclient.cookie.Cookie;
-import org.asynchttpclient.multipart.Part;
-
-import java.io.InputStream;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-
-public class BoundRequestBuilder extends RequestBuilderBaseAdds a listener and executor to the ListenableFuture. - * The listener will be {@linkplain java.util.concurrent.Executor#execute(Runnable) passed - * to the executor} for execution when the {@code Future}'s computation is - * {@linkplain Future#isDone() complete}. - *
- *There is no guaranteed ordering of execution of listeners, they may get
- * called in the order they were added and they may get called out of order,
- * but any listener added through this method is guaranteed to be called once
- * the computation is complete.
- *
- * @param listener the listener to run when the computation is complete.
- * @param exec the executor to run the listener in.
- * @return this Future
- * @throws NullPointerException if the executor or listener was null.
- * @throws java.util.concurrent.RejectedExecutionException
- * if we tried to execute the listener
- * immediately but the executor rejected it.
- */
- ListenableFuture
- * Sun, 06 Nov 1994 08:49:37 GMT -> E, d MMM yyyy HH:mm:ss z
- */
- private RFC2616DateParser() {
- super("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
- setTimeZone(TimeZone.getTimeZone("GMT"));
- }
-
- @Override
- public Date parse(String text, ParsePosition pos) {
- Date date = super.parse(text, pos);
- if (date == null) {
- date = format1.parse(text, pos);
- }
- if (date == null) {
- date = format2.parse(text, pos);
- }
- return date;
- }
-
- /**
- * First obsolete format
- * Sunday, 06-Nov-94 08:49:37 GMT -> E, d-MMM-y HH:mm:ss z
- */
- private static final class RFC2616DateParserObsolete1 extends SimpleDateFormat {
- private static final long serialVersionUID = -3178072504225114298L;
-
- RFC2616DateParserObsolete1() {
- super("E, dd-MMM-yy HH:mm:ss z", Locale.ENGLISH);
- setTimeZone(TimeZone.getTimeZone("GMT"));
- }
- }
-
- /**
- * Second obsolete format
- *
- * Sun Nov 6 08:49:37 1994 -> EEE, MMM d HH:mm:ss yyyy
- */
- private static final class RFC2616DateParserObsolete2 extends SimpleDateFormat {
- private static final long serialVersionUID = 3010674519968303714L;
-
- RFC2616DateParserObsolete2() {
- super("E MMM d HH:mm:ss yyyy", Locale.ENGLISH);
- setTimeZone(TimeZone.getTimeZone("GMT"));
- }
- }
-}
diff --git a/api/src/main/java/org/asynchttpclient/extra/AsyncHandlerWrapper.java b/api/src/main/java/org/asynchttpclient/extra/AsyncHandlerWrapper.java
deleted file mode 100644
index 3ce9527270..0000000000
--- a/api/src/main/java/org/asynchttpclient/extra/AsyncHandlerWrapper.java
+++ /dev/null
@@ -1,79 +0,0 @@
-package org.asynchttpclient.extra;
-
-import org.asynchttpclient.AsyncHandler;
-import org.asynchttpclient.HttpResponseBodyPart;
-import org.asynchttpclient.HttpResponseHeaders;
-import org.asynchttpclient.HttpResponseStatus;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.concurrent.Semaphore;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-public class AsyncHandlerWrapper An abstract base implementation of the listener support provided by
- * {@link ListenableFuture}. This class uses an {@link ExecutionList} to
- * guarantee that all registered listeners will be executed. Listener/Executor
- * pairs are stored in the execution list and executed in the order in which
- * they were added, but because of thread scheduling issues there is no
- * guarantee that the JVM will execute them in order. In addition, listeners
- * added after the task is complete will be executed immediately, even if some
- * previously added listeners have not yet been executed.
- *
- * @author Sven Mawson
- * @since 1
- */
-public abstract class AbstractListenableFuture
- */
-public interface Request {
-
- /**
- * Return the request's method name (GET, POST, etc.)
- *
- * @return the request's method name (GET, POST, etc.)
- */
- String getMethod();
-
- Uri getUri();
-
- String getUrl();
-
- /**
- * Return the InetAddress to override
- *
- * @return the InetAddress
- */
- InetAddress getInetAddress();
-
- InetAddress getLocalAddress();
-
- /**
- * Return the current set of Headers.
- *
- * @return a {@link FluentCaseInsensitiveStringsMap} contains headers.
- */
- FluentCaseInsensitiveStringsMap getHeaders();
-
- /**
- * Return Coookie.
- *
- * @return an unmodifiable Collection of Cookies
- */
- Collection
- * Request r = new RequestBuilder().setUrl("url")
- * .setRealm((new Realm.RealmBuilder()).setPrincipal(user)
- * .setPassword(admin)
- * .setRealmName("MyRealm")
- * .setScheme(Realm.AuthScheme.DIGEST).build());
- *
- * or
- *
- * SimpleAsyncHttpClient client = new SimpleAsyncHttpClient.Builder()
- * .setIdleConnectionInPoolTimeout(100)
- * .setMaximumConnectionsTotal(50)
- * .setRequestTimeout(5 * 60 * 1000)
- * .setUrl(getTargetUrl())
- * .setHeader("Content-Type", "text/html").build();
- *
- * StringBuilder s = new StringBuilder();
- * Future
- */
-public class SimpleAsyncHttpClient implements Closeable {
-
- private final AsyncHttpClientConfig config;
- private final RequestBuilder requestBuilder;
- private AsyncHttpClient asyncHttpClient;
- private final ThrowableHandler defaultThrowableHandler;
- private final boolean resumeEnabled;
- private final ErrorDocumentBehaviour errorDocumentBehaviour;
- private final SimpleAHCTransferListener listener;
- private final boolean derived;
- private final String providerClass;
-
- private SimpleAsyncHttpClient(AsyncHttpClientConfig config, RequestBuilder requestBuilder, ThrowableHandler defaultThrowableHandler,
- ErrorDocumentBehaviour errorDocumentBehaviour, boolean resumeEnabled, AsyncHttpClient ahc, SimpleAHCTransferListener listener,
- String providerClass) {
- this.config = config;
- this.requestBuilder = requestBuilder;
- this.defaultThrowableHandler = defaultThrowableHandler;
- this.resumeEnabled = resumeEnabled;
- this.errorDocumentBehaviour = errorDocumentBehaviour;
- this.asyncHttpClient = ahc;
- this.listener = listener;
- this.providerClass = providerClass;
-
- this.derived = ahc != null;
- }
-
- public Future
- * public void ByteArrayOutputStreamBodyConsumerTest() throws Throwable {
- *
- * SimpleAsyncHttpClient client = new SimpleAsyncHttpClient.Builder()
- * .setUrl(getTargetUrl())
- * .build();
- *
- * ByteArrayOutputStream o = new ByteArrayOutputStream(10);
- * Future