org.apache.ambari.server.controller.internal

Class URLStreamProvider

java.lang.Object

org.apache.ambari.server.controller.internal.URLStreamProvider

All Implemented Interfaces:

StreamProvider

public class URLStreamProvider
extends Object
implements StreamProvider

URL based implementation of a stream provider.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	URLStreamProvider.AmbariHttpUrlConnectionProvider A default implementation of HttpURLConnectionProvider, this class will use the URLStreamProvider in order to provide an HttpURLConnection which is able to use Ambari's cookie store, truststore, and timeout values.

Field Summary

Fields

Modifier and Type	Field and Description
static String	COOKIE

Constructor Summary

Constructors

Constructor and Description
URLStreamProvider(int connectionTimeout, int readTimeout, ComponentSSLConfiguration configuration) Provide the connection timeout for the underlying connection.
URLStreamProvider(int connectionTimeout, int readTimeout, String trustStorePath, String trustStorePassword, String trustStoreType) Provide the connection timeout for the underlying connection.

Method Summary

Modifier and Type	Method and Description
static String	appendCookie(String cookies, String newCookie) Utility method to append a new cookie value to an existing list of cookies.
AppCookieManager	getAppCookieManager() Get the associated app cookie manager.
protected HttpURLConnection	getConnection(String spec)
boolean	getSetupTruststoreForHttps()
protected HttpsURLConnection	getSSLConnection(String spec)
HttpURLConnection	processURL(String spec, String requestMethod, byte[] body, Map<String,List<String>> headers) Get a URL connection from the given spec.
HttpURLConnection	processURL(String spec, String requestMethod, InputStream body, Map<String,List<String>> headers) Get a URL connection from the given spec.
HttpURLConnection	processURL(String spec, String requestMethod, String body, Map<String,List<String>> headers) Get a URL connection from the given spec.
InputStream	readFrom(String spec)
InputStream	readFrom(String spec, String requestMethod, String params)
void	setSetupTruststoreForHttps(boolean setupTruststoreForHttps)

Methods inherited from class java.lang.Object

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

Field Detail

COOKIE

public static final String COOKIE

See Also:

Constant Field Values

Constructor Detail

URLStreamProvider

public URLStreamProvider(int connectionTimeout,
                         int readTimeout,
                         ComponentSSLConfiguration configuration)

Provide the connection timeout for the underlying connection.

Parameters:

connectionTimeout - time, in milliseconds, to attempt a connection

readTimeout - the read timeout in milliseconds

configuration - configuration holding TrustStore information

URLStreamProvider

public URLStreamProvider(int connectionTimeout,
                         int readTimeout,
                         String trustStorePath,
                         String trustStorePassword,
                         String trustStoreType)

Provide the connection timeout for the underlying connection.

Parameters:

connectionTimeout - time, in milliseconds, to attempt a connection

readTimeout - the read timeout in milliseconds

trustStorePath - the path to the truststore required for secure connections

trustStorePassword - the truststore password

trustStoreType - the truststore type (e.g. "JKS")

Method Detail

setSetupTruststoreForHttps

public void setSetupTruststoreForHttps(boolean setupTruststoreForHttps)

getSetupTruststoreForHttps

public boolean getSetupTruststoreForHttps()

readFrom

public InputStream readFrom(String spec,
                            String requestMethod,
                            String params)
                     throws IOException

Specified by:

readFrom in interface StreamProvider

Throws:

IOException

readFrom

public InputStream readFrom(String spec)
                     throws IOException

Specified by:

readFrom in interface StreamProvider

Throws:

IOException

processURL

public HttpURLConnection processURL(String spec,
                                    String requestMethod,
                                    String body,
                                    Map<String,List<String>> headers)
                             throws IOException

Get a URL connection from the given spec.

Parameters:

spec - the String to parse as a URL

requestMethod - the HTTP method (GET,POST,PUT,etc.).

body - the body of the request; may be null

headers - the headers of the request; may be null

Returns:

a URL connection

Throws:

IOException - if the URL connection can not be established

processURL

public HttpURLConnection processURL(String spec,
                                    String requestMethod,
                                    InputStream body,
                                    Map<String,List<String>> headers)
                             throws IOException

Get a URL connection from the given spec.

Parameters:

spec - the String to parse as a URL

requestMethod - the HTTP method (GET,POST,PUT,etc.).

body - the body of the request; may be null

headers - the headers of the request; may be null

Returns:

a URL connection

Throws:

IOException - if the URL connection can not be established

processURL

public HttpURLConnection processURL(String spec,
                                    String requestMethod,
                                    byte[] body,
                                    Map<String,List<String>> headers)
                             throws IOException

Get a URL connection from the given spec.

Parameters:

spec - the String to parse as a URL

requestMethod - the HTTP method (GET,POST,PUT,etc.).

body - the body of the request; may be null

headers - the headers of the request; may be null

Returns:

a URL connection

Throws:

IOException - if the URL connection can not be established

getAppCookieManager

public AppCookieManager getAppCookieManager()

Get the associated app cookie manager.

Returns:

the app cookie manager

appendCookie

public static String appendCookie(String cookies,
                                  String newCookie)

Utility method to append a new cookie value to an existing list of cookies.

Parameters:

cookies - the semicolon separated list of cookie values

newCookie - a new cookie value to be appended.

Returns:

the new list of cookie values

getConnection

protected HttpURLConnection getConnection(String spec)
                                   throws IOException

Throws:

IOException

getSSLConnection

protected HttpsURLConnection getSSLConnection(String spec)
                                       throws IOException,
                                              IllegalStateException

Throws:

IOException

IllegalStateException