- * 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;
- }
-
- /**
- * 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;
- }
-
- public int getHttpClientCodecMaxInitialLineLength() {
- return httpClientCodecMaxInitialLineLength;
- }
-
- public int getHttpClientCodecMaxHeaderSize() {
- return httpClientCodecMaxHeaderSize;
- }
-
- public int getHttpClientCodecMaxChunkSize() {
- return httpClientCodecMaxChunkSize;
- }
-
- public boolean isDisableZeroCopy() {
- return disableZeroCopy;
- }
-
- public long getHandshakeTimeout() {
- return handshakeTimeout;
- }
-
- public SSLEngineFactory getSslEngineFactory() {
- return sslEngineFactory;
- }
-
- public int getChunkedFileChunkSize() {
- return chunkedFileChunkSize;
- }
-
- public int getWebSocketMaxBufferSize() {
- return webSocketMaxBufferSize;
- }
-
- public int getWebSocketMaxFrameSize() {
- return webSocketMaxFrameSize;
- }
-
- public boolean isKeepEncodingHeader() {
- return keepEncodingHeader;
- }
-
- /**
- * 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 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;
- }
-
- 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;
- }
-
- public Builder setHttpClientCodecMaxInitialLineLength(int httpClientCodecMaxInitialLineLength) {
- this.httpClientCodecMaxInitialLineLength = httpClientCodecMaxInitialLineLength;
- return this;
- }
-
- public Builder setHttpClientCodecMaxHeaderSize(int httpClientCodecMaxHeaderSize) {
- this.httpClientCodecMaxHeaderSize = httpClientCodecMaxHeaderSize;
- return this;
- }
-
- public Builder setHttpClientCodecMaxChunkSize(int httpClientCodecMaxChunkSize) {
- this.httpClientCodecMaxChunkSize = httpClientCodecMaxChunkSize;
- return this;
- }
-
- public Builder setDisableZeroCopy(boolean disableZeroCopy) {
- this.disableZeroCopy = disableZeroCopy;
- return this;
- }
-
- public Builder setHandshakeTimeout(long handshakeTimeout) {
- this.handshakeTimeout = handshakeTimeout;
- return this;
- }
-
- public Builder setSslEngineFactory(SSLEngineFactory sslEngineFactory) {
- this.sslEngineFactory = sslEngineFactory;
- return this;
- }
-
- public Builder setChunkedFileChunkSize(int chunkedFileChunkSize) {
- this.chunkedFileChunkSize = chunkedFileChunkSize;
- return this;
- }
-
- public Builder setWebSocketMaxBufferSize(int webSocketMaxBufferSize) {
- this.webSocketMaxBufferSize = webSocketMaxBufferSize;
- return this;
- }
-
- public Builder setWebSocketMaxFrameSize(int webSocketMaxFrameSize) {
- this.webSocketMaxFrameSize = webSocketMaxFrameSize;
- return this;
- }
-
- public Builder setKeepEncodingHeader(boolean keepEncodingHeader) {
- this.keepEncodingHeader = keepEncodingHeader;
- 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();
- 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;
- httpClientCodecMaxInitialLineLength = prototype.httpClientCodecMaxInitialLineLength;
- httpClientCodecMaxHeaderSize = prototype.httpClientCodecMaxHeaderSize;
- httpClientCodecMaxChunkSize = prototype.httpClientCodecMaxChunkSize;
- disableZeroCopy = prototype.disableZeroCopy;
- handshakeTimeout = prototype.handshakeTimeout;
- sslEngineFactory = prototype.sslEngineFactory;
- chunkedFileChunkSize = prototype.chunkedFileChunkSize;
- webSocketMaxBufferSize = prototype.webSocketMaxBufferSize;
- webSocketMaxFrameSize = prototype.webSocketMaxFrameSize;
- keepEncodingHeader = prototype.keepEncodingHeader;
-
- providerConfig = prototype.getAsyncHttpProviderConfig();
- }
-
- /**
- * 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, //
- compressionEnforced, //
- userAgent,//
- realm,//
- requestFilters, //
- responseFilters,//
- ioExceptionFilters,//
- maxRequestRetry, //
- disableUrlEncodingForBoundRequests, //
- ioThreadMultiplier, //
- enabledProtocols, //
- enabledCipherSuites, //
- sslSessionCacheSize, //
- sslSessionTimeout, //
- httpClientCodecMaxInitialLineLength, //
- httpClientCodecMaxHeaderSize, //
- httpClientCodecMaxChunkSize, //
- disableZeroCopy, //
- handshakeTimeout, //
- sslEngineFactory, //
- chunkedFileChunkSize, //
- webSocketMaxBufferSize, //
- webSocketMaxFrameSize, //
- keepEncodingHeader, //
- providerConfig);
- }
- }
-}
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.
- */
- Adds 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 7738990dff..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 A list of ({@code Runnable}, {@code Executor}) pairs that guarantees
- * that every {@code Runnable} that is added using the add method will be
- * executed in its associated {@code Executor} after {@link #run()} is called.
- * {@code Runnable}s added after {@code run} is called are still guaranteed to
- * execute.
- *
- * @author Nishant Thakkar
- * @author Sven Mawson
- * @since 1
- */
-public final class ExecutionList implements Runnable {
-
- // Logger to log exceptions caught when running runnables.
- private static final Logger log = Logger.getLogger(ExecutionList.class.getName());
-
- // The runnable,executor pairs to execute.
- private final Queue Retrieval operations (including {@code get}) generally do not
- * block, so may overlap with update operations (including {@code put}
- * and {@code remove}). Retrievals reflect the results of the most
- * recently completed update operations holding upon their
- * onset. (More formally, an update operation for a given key bears a
- * happens-before relation with any (non-null) retrieval for
- * that key reporting the updated value.) For aggregate operations
- * such as {@code putAll} and {@code clear}, concurrent retrievals may
- * reflect insertion or removal of only some entries. Similarly,
- * Iterators and Enumerations return elements reflecting the state of
- * the hash table at some point at or since the creation of the
- * iterator/enumeration. They do not throw {@link
- * ConcurrentModificationException}. However, iterators are designed
- * to be used by only one thread at a time. Bear in mind that the
- * results of aggregate status methods including {@code size}, {@code
- * isEmpty}, and {@code containsValue} are typically useful only when
- * a map is not undergoing concurrent updates in other threads.
- * Otherwise the results of these methods reflect transient states
- * that may be adequate for monitoring or estimation purposes, but not
- * for program control.
- *
- * The table is dynamically expanded when there are too many
- * collisions (i.e., keys that have distinct hash codes but fall into
- * the same slot modulo the table size), with the expected average
- * effect of maintaining roughly two bins per mapping (corresponding
- * to a 0.75 load factor threshold for resizing). There may be much
- * variance around this average as mappings are added and removed, but
- * overall, this maintains a commonly accepted time/space tradeoff for
- * hash tables. However, resizing this or any other kind of hash
- * table may be a relatively slow operation. When possible, it is a
- * good idea to provide a size estimate as an optional {@code
- * initialCapacity} constructor argument. An additional optional
- * {@code loadFactor} constructor argument provides a further means of
- * customizing initial table capacity by specifying the table density
- * to be used in calculating the amount of space to allocate for the
- * given number of elements. Also, for compatibility with previous
- * versions of this class, constructors may optionally specify an
- * expected {@code concurrencyLevel} as an additional hint for
- * internal sizing. Note that using many keys with exactly the same
- * {@code hashCode()} is a sure way to slow down performance of any
- * hash table. To ameliorate impact, when keys are {@link Comparable},
- * this class may use comparison order among keys to help break ties.
- *
- * A {@link Set} projection of a ConcurrentHashMapV8 may be created
- * (using {@link #newKeySet()} or {@link #newKeySet(int)}), or viewed
- * (using {@link #keySet(Object)} when only keys are of interest, and the
- * mapped values are (perhaps transiently) not used or all take the
- * same mapping value.
- *
- * This class and its views and iterators implement all of the
- * optional methods of the {@link Map} and {@link Iterator}
- * interfaces.
- *
- * Like {@link Hashtable} but unlike {@link HashMap}, this class
- * does not allow {@code null} to be used as a key or value.
- *
- * ConcurrentHashMapV8s support a set of sequential and parallel bulk
- * operations that are designed
- * to be safely, and often sensibly, applied even with maps that are
- * being concurrently updated by other threads; for example, when
- * computing a snapshot summary of the values in a shared registry.
- * There are three kinds of operation, each with four forms, accepting
- * functions with Keys, Values, Entries, and (Key, Value) arguments
- * and/or return values. Because the elements of a ConcurrentHashMapV8
- * are not ordered in any particular way, and may be processed in
- * different orders in different parallel executions, the correctness
- * of supplied functions should not depend on any ordering, or on any
- * other objects or values that may transiently change while
- * computation is in progress; and except for forEach actions, should
- * ideally be side-effect-free. Bulk operations on {@link java.util.Map.Entry}
- * objects do not support method {@code setValue}.
- *
- * These bulk operations accept a {@code parallelismThreshold}
- * argument. Methods proceed sequentially if the current map size is
- * estimated to be less than the given threshold. Using a value of
- * {@code Long.MAX_VALUE} suppresses all parallelism. Using a value
- * of {@code 1} results in maximal parallelism by partitioning into
- * enough subtasks to fully utilize the {@link
- * ForkJoinPool#commonPool()} that is used for all parallel
- * computations. Normally, you would initially choose one of these
- * extreme values, and then measure performance of using in-between
- * values that trade off overhead versus throughput.
- *
- * The concurrency properties of bulk operations follow
- * from those of ConcurrentHashMapV8: Any non-null result returned
- * from {@code get(key)} and related access methods bears a
- * happens-before relation with the associated insertion or
- * update. The result of any bulk operation reflects the
- * composition of these per-element relations (but is not
- * necessarily atomic with respect to the map as a whole unless it
- * is somehow known to be quiescent). Conversely, because keys
- * and values in the map are never null, null serves as a reliable
- * atomic indicator of the current lack of any result. To
- * maintain this property, null serves as an implicit basis for
- * all non-scalar reduction operations. For the double, long, and
- * int versions, the basis should be one that, when combined with
- * any other value, returns that other value (more formally, it
- * should be the identity element for the reduction). Most common
- * reductions have these properties; for example, computing a sum
- * with basis 0 or a minimum with basis MAX_VALUE.
- *
- * Search and transformation functions provided as arguments
- * should similarly return null to indicate the lack of any result
- * (in which case it is not used). In the case of mapped
- * reductions, this also enables transformations to serve as
- * filters, returning null (or, in the case of primitive
- * specializations, the identity basis) if the element should not
- * be combined. You can create compound transformations and
- * filterings by composing them yourself under this "null means
- * there is nothing there now" rule before using them in search or
- * reduce operations.
- *
- * Methods accepting and/or returning Entry arguments maintain
- * key-value associations. They may be useful for example when
- * finding the key for the greatest value. Note that "plain" Entry
- * arguments can be supplied using {@code new
- * AbstractMap.SimpleEntry(k,v)}.
- *
- * Bulk operations may complete abruptly, throwing an
- * exception encountered in the application of a supplied
- * function. Bear in mind when handling such exceptions that other
- * concurrently executing functions could also have thrown
- * exceptions, or would have done so if the first exception had
- * not occurred.
- *
- * Speedups for parallel compared to sequential forms are common
- * but not guaranteed. Parallel operations involving brief functions
- * on small maps may execute more slowly than sequential forms if the
- * underlying work to parallelize the computation is more expensive
- * than the computation itself. Similarly, parallelization may not
- * lead to much actual parallelism if all processors are busy
- * performing unrelated tasks.
- *
- * All arguments to all task methods must be non-null.
- *
- * jsr166e note: During transition, this class
- * uses nested functional interfaces with different names but the
- * same forms as those expected for JDK8.
- *
- * This class is a member of the
- *
- * Java Collections Framework.
- *
- * @since 1.5
- * @author Doug Lea
- * @param
- */
-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());
- * 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 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/handler/MaxRedirectException.java b/api/src/main/java/org/asynchttpclient/handler/MaxRedirectException.java
deleted file mode 100644
index e6ca7a51a5..0000000000
--- a/api/src/main/java/org/asynchttpclient/handler/MaxRedirectException.java
+++ /dev/null
@@ -1,30 +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.handler;
-
-import org.asynchttpclient.AsyncHttpClientConfig;
-
-/**
- * Thrown when the {@link AsyncHttpClientConfig#getMaxRedirects()} has been reached.
- */
-public class MaxRedirectException extends Exception {
- private static final long serialVersionUID = 1L;
-
- public MaxRedirectException(String msg) {
- super(msg, null, true, false);
- }
-}
diff --git a/api/src/main/java/org/asynchttpclient/handler/TransferCompletionHandler.java b/api/src/main/java/org/asynchttpclient/handler/TransferCompletionHandler.java
deleted file mode 100644
index e95000e9a3..0000000000
--- a/api/src/main/java/org/asynchttpclient/handler/TransferCompletionHandler.java
+++ /dev/null
@@ -1,241 +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.handler;
-
-import org.asynchttpclient.AsyncCompletionHandlerBase;
-import org.asynchttpclient.FluentCaseInsensitiveStringsMap;
-import org.asynchttpclient.HttpResponseBodyPart;
-import org.asynchttpclient.HttpResponseHeaders;
-import org.asynchttpclient.Response;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.concurrent.ConcurrentLinkedQueue;
-
-/**
- * A {@link org.asynchttpclient.AsyncHandler} that can be used to notify a set of {@link TransferListener}
- *
- *
- *
- *
- */
-public class TransferCompletionHandler extends AsyncCompletionHandlerBase {
- private final static Logger logger = LoggerFactory.getLogger(TransferCompletionHandler.class);
- private final ConcurrentLinkedQueue
- * AsyncHttpClient client = new AsyncHttpClient();
- * TransferCompletionHandler tl = new TransferCompletionHandler();
- * tl.addTransferListener(new TransferListener() {
- *
- * public void onRequestHeadersSent(FluentCaseInsensitiveStringsMap headers) {
- * }
- *
- * public void onResponseHeadersReceived(FluentCaseInsensitiveStringsMap headers) {
- * }
- *
- * public void onBytesReceived(ByteBuffer buffer) {
- * }
- *
- * public void onBytesSent(long amount, long current, long total) {
- * }
- *
- * public void onRequestResponseCompleted() {
- * }
- *
- * public void onThrowable(Throwable t) {
- * }
- * });
- *
- * Response response = httpClient.prepareGet("http://.../").execute(tl).get();
- *
- *
- *
- *
- *
- *
- *
- *
- *