Package aQute.bnd.http

Class HttpClient

java.lang.Object

aQute.bnd.http.HttpClient

All Implemented Interfaces:

URLConnector, Closeable, AutoCloseable

public class HttpClient
extends Object
implements Closeable, URLConnector

A simple Http Client that inter-works with the bnd registry. It provides an easy way to construct a URL request. The request is then decorated with third parties that are in the bnd registry for proxies and authentication models.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	HttpClient.HttpConnection<T>

Field Summary

Fields

Modifier and Type	Field	Description
private URLCache	cache
(package private) static final JSONCodec	codec
private final List<URLConnectionHandler>	connectionHandlers
private ConnectionSettings	connectionSettings
(package private) static final long	FINAL_TIMEOUT
private boolean	inited
(package private) static final long	INITIAL_TIMEOUT
(package private) static final org.slf4j.Logger	logger
(package private) static final long	MAX_RETRY_DELAY
private AtomicBoolean	offline
private ThreadLocal<PasswordAuthentication>	passwordAuthentication
private final org.osgi.util.promise.PromiseFactory	promiseFactory
private final List<ProxyHandler>	proxyHandlers
private Registry	registry
private Reporter	reporter
(package private) int	retries
(package private) long	retryDelay
static final SimpleDateFormat	sdf	Deprecated.

Constructor Summary

Constructors

Constructor	Description
HttpClient()

Method Summary

Modifier and Type	Method	Description
void	addProxyHandler(ProxyHandler proxyHandler)
void	addURLConnectionHandler(URLConnectionHandler handler)
HttpRequest<Object>	build()
URLCache	cache()
void	close()
InputStream	connect(URL url)	Connect to the specified URL.
TaggedData	connectTagged(URL url)	Connect to the specified URL, also returning the ETag if available.
TaggedData	connectTagged(URL url, String tag)	Connect to the specified URL while providing the last known tag for the remote resource; the response will be null if the remote resource is unchanged.
<T> T	connectWithProxy(ProxyHandler.ProxySetup proxySetup, Callable<T> r)
(package private) InputStream	createProgressWrappedStream(InputStream inputStream, String name, int size, ProgressPlugin.Task task, long timeout)
URLConnectionHandler	findMatchingHandler(URL url)
File	getCacheFileFor(URI url)
private Collection<? extends ProxyHandler>	getProxyHandlers()
ProxyHandler.ProxySetup	getProxySetup(URL url)
Reporter	getReporter()
private Collection<? extends URLConnectionHandler>	getURLConnectionHandlers()
String	getUserFor(String base)
(package private) void	init()
boolean	isOffline()
URI	makeDir(URI uri)
org.osgi.util.promise.PromiseFactory	promiseFactory()
void	readSettings(Processor processor)
void	reportSettings(Formatter out)
HttpClient	retries(int retries)
HttpClient	retryDelay(int retryDelay)
<T> T	send(HttpRequest<T> request)
TaggedData	send0(HttpRequest<?> request)
(package private) <T> org.osgi.util.promise.Promise<T>	sendAsync(HttpRequest<T> request)
private <T> org.osgi.util.promise.Promise<T>	sendAsync(HttpRequest<T> request, int retries, long delay)
void	setCache(File cache)
void	setLog(File log)
void	setOffline(AtomicBoolean offline)
void	setRegistry(Registry registry)
void	setReporter(Reporter reporter)
String	toName(URI url)
String	validateURI(URI u)	Validate a URI to see if it is supported by this client

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

static final org.slf4j.Logger logger

sdf

@Deprecated
public static final SimpleDateFormat sdf

Deprecated.

INITIAL_TIMEOUT

static final long INITIAL_TIMEOUT

FINAL_TIMEOUT

static final long FINAL_TIMEOUT

MAX_RETRY_DELAY

static final long MAX_RETRY_DELAY

proxyHandlers

private final List<ProxyHandler> proxyHandlers

connectionHandlers

private final List<URLConnectionHandler> connectionHandlers

passwordAuthentication

private ThreadLocal<PasswordAuthentication> passwordAuthentication

inited

private boolean inited

codec

static final JSONCodec codec

cache

private URLCache cache

registry

private Registry registry

reporter

private Reporter reporter

offline

private volatile AtomicBoolean offline

promiseFactory

private final org.osgi.util.promise.PromiseFactory promiseFactory

connectionSettings

private ConnectionSettings connectionSettings

retries

int retries

retryDelay

long retryDelay

Constructor Details

HttpClient

public HttpClient()

Method Details

init

void init()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

connect

public InputStream connect(URL url)
                    throws Exception

Description copied from interface: URLConnector

Connect to the specified URL.

Specified by:

connect in interface URLConnector

Throws:

IOException

Exception

connectTagged

public TaggedData connectTagged(URL url)
                         throws Exception

Description copied from interface: URLConnector

Connect to the specified URL, also returning the ETag if available.

Specified by:

connectTagged in interface URLConnector

Parameters:

url - The remote URL.

Returns:

An instance of TaggedData; note that the TaggedData.getTag() method may return null if the resource has no tag.

Throws:

IOException - @since 1.1

Exception

connectTagged

public TaggedData connectTagged(URL url,
 String tag)
                         throws Exception

Description copied from interface: URLConnector

Connect to the specified URL while providing the last known tag for the remote resource; the response will be null if the remote resource is unchanged.

Specified by:

connectTagged in interface URLConnector

Parameters:

url - The remote URL.

tag - The last known tag value for the resource.

Returns:

An instance of TaggedData, or null if the resource has not modified (i.e., if it has the same tag value).

Throws:

IOException - @since 1.1

Exception

build

public HttpRequest<Object> build()

sendAsync

<T> org.osgi.util.promise.Promise<T> sendAsync(HttpRequest<T> request)

sendAsync

private <T> org.osgi.util.promise.Promise<T> sendAsync(HttpRequest<T> request,
 int retries,
 long delay)

send

public <T> T send(HttpRequest<T> request)
           throws Exception

Throws:

Exception

send0

public TaggedData send0(HttpRequest<?> request)
                 throws Exception

Throws:

Exception

getProxySetup

public ProxyHandler.ProxySetup getProxySetup(URL url)
                                      throws Exception

Throws:

Exception

connectWithProxy

public <T> T connectWithProxy(ProxyHandler.ProxySetup proxySetup,
 Callable<T> r)
                       throws Exception

Throws:

Exception

findMatchingHandler

public URLConnectionHandler findMatchingHandler(URL url)

getURLConnectionHandlers

private Collection<? extends URLConnectionHandler> getURLConnectionHandlers()

getProxyHandlers

private Collection<? extends ProxyHandler> getProxyHandlers()
                                                     throws Exception

Throws:

Exception

createProgressWrappedStream

InputStream createProgressWrappedStream(InputStream inputStream,
 String name,
 int size,
 ProgressPlugin.Task task,
 long timeout)

setCache

public void setCache(File cache)

setReporter

public void setReporter(Reporter reporter)

setRegistry

public void setRegistry(Registry registry)

addURLConnectionHandler

public void addURLConnectionHandler(URLConnectionHandler handler)

getReporter

public Reporter getReporter()

addProxyHandler

public void addProxyHandler(ProxyHandler proxyHandler)

setLog

public void setLog(File log)
            throws IOException

Throws:

IOException

getUserFor

public String getUserFor(String base)
                  throws MalformedURLException,
Exception

Throws:

MalformedURLException

Exception

toName

public String toName(URI url)
              throws Exception

Throws:

Exception

getCacheFileFor

public File getCacheFileFor(URI url)
                     throws Exception

Throws:

Exception

readSettings

public void readSettings(Processor processor)
                  throws IOException,
Exception

Throws:

IOException

Exception

makeDir

public URI makeDir(URI uri)
            throws URISyntaxException

Throws:

URISyntaxException

isOffline

public boolean isOffline()

setOffline

public void setOffline(AtomicBoolean offline)

promiseFactory

public org.osgi.util.promise.PromiseFactory promiseFactory()

cache

public URLCache cache()

reportSettings

public void reportSettings(Formatter out)

retries

public HttpClient retries(int retries)

retryDelay

public HttpClient retryDelay(int retryDelay)

validateURI

public String validateURI(URI u)

Validate a URI to see if it is supported by this client

Parameters:

u - the uri

Returns:

null if ok, otherwise a reason why it is invalid