org.jclouds.http

Class HttpUtils

java.lang.Object

org.jclouds.http.HttpUtils

@Singleton
public class HttpUtils
extends Object

Author:

Adrian Cole

Constructor Summary

Constructors

Constructor and Description
HttpUtils(int connectionTimeout, int soTimeout, int globalMaxConnections, int globalMaxConnectionsPerHost)

Method Summary

Methods

Modifier and Type	Method and Description
static Long	attemptToParseSizeAndRangeFromHeaders(HttpMessage from)
static void	checkRequestHasContentLengthOrChunkedEncoding(HttpMessage request, String message)
void	checkRequestHasRequiredProperties(HttpRequest message)
static byte[]	closeClientButKeepContentStream(PayloadEnclosing response) Content stream may need to be read.
static void	copy(ContentMetadata fromMd, MutableContentMetadata toMd)
int	getConnectionTimeout()
int	getMaxConnections()
int	getMaxConnectionsPerHost()
String	getProxyHost()
String	getProxyPassword()
Integer	getProxyPort()
String	getProxyUser()
int	getSocketOpenTimeout()
void	logRequest(Logger logger, HttpRequest request, String prefix)
void	logResponse(Logger logger, HttpResponse response, String prefix)
static String	nullToEmpty(byte[] md5)
static String	nullToEmpty(Collection<String> collection)
boolean	relaxHostname()
static void	releasePayload(HttpMessage from)
static <T> T	returnValueOnCodeOrNull(Exception from, T value, com.google.common.base.Predicate<Integer> codePredicate)
static byte[]	toByteArrayOrNull(PayloadEnclosing response)
boolean	trustAllCerts()
boolean	useSystemProxies()
static void	wirePayloadIfEnabled(Wire wire, HttpMessage request)

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpUtils

@Inject
public HttpUtils(@Named(value="jclouds.connection-timeout")
                int connectionTimeout,
                @Named(value="jclouds.so-timeout")
                int soTimeout,
                @Named(value="jclouds.max-connections-per-context")
                int globalMaxConnections,
                @Named(value="jclouds.max-connections-per-host")
                int globalMaxConnectionsPerHost)

Method Detail

getProxyHost

public String getProxyHost()

See Also:

org.jclouds.Constants.PROPERTY_PROXY_HOST

getProxyPort

public Integer getProxyPort()

See Also:

org.jclouds.Constants.PROPERTY_PROXY_PORT

getProxyUser

public String getProxyUser()

See Also:

org.jclouds.Constants.PROPERTY_PROXY_USER

getProxyPassword

public String getProxyPassword()

See Also:

org.jclouds.Constants.PROPERTY_PROXY_PASSWORD

getSocketOpenTimeout

public int getSocketOpenTimeout()

getConnectionTimeout

public int getConnectionTimeout()

relaxHostname

public boolean relaxHostname()

trustAllCerts

public boolean trustAllCerts()

useSystemProxies

public boolean useSystemProxies()

getMaxConnections

public int getMaxConnections()

getMaxConnectionsPerHost

public int getMaxConnectionsPerHost()

toByteArrayOrNull

public static byte[] toByteArrayOrNull(PayloadEnclosing response)

closeClientButKeepContentStream

public static byte[] closeClientButKeepContentStream(PayloadEnclosing response)

Content stream may need to be read. However, we should always close the http stream.

Throws:

IOException

copy

public static void copy(ContentMetadata fromMd,
        MutableContentMetadata toMd)

logRequest

public void logRequest(Logger logger,
              HttpRequest request,
              String prefix)

logResponse

public void logResponse(Logger logger,
               HttpResponse response,
               String prefix)

checkRequestHasRequiredProperties

public void checkRequestHasRequiredProperties(HttpRequest message)

releasePayload

public static void releasePayload(HttpMessage from)

nullToEmpty

public static String nullToEmpty(byte[] md5)

nullToEmpty

public static String nullToEmpty(Collection<String> collection)

attemptToParseSizeAndRangeFromHeaders

public static Long attemptToParseSizeAndRangeFromHeaders(HttpMessage from)
                                                  throws HttpException

Throws:

HttpException

checkRequestHasContentLengthOrChunkedEncoding

public static void checkRequestHasContentLengthOrChunkedEncoding(HttpMessage request,
                                                 String message)

wirePayloadIfEnabled

public static void wirePayloadIfEnabled(Wire wire,
                        HttpMessage request)

returnValueOnCodeOrNull

public static <T> T returnValueOnCodeOrNull(Exception from,
                            T value,
                            com.google.common.base.Predicate<Integer> codePredicate)