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.

Constructor Summary

Constructors

Constructor and Description
URLStreamProvider(int connectionTimeout, int readTimeout, String path, String password, String type) Provide the connection timeout for the underlying connection.

Method Summary

Modifier and Type	Method and Description
HttpURLConnection	processURL(String spec, String requestMethod, Object params, Map<String,List<String>> headers)
InputStream	readFrom(String spec)
InputStream	readFrom(String spec, String requestMethod, String params)

Methods inherited from class java.lang.Object

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

Constructor Detail

URLStreamProvider

public URLStreamProvider(int connectionTimeout,
                         int readTimeout,
                         String path,
                         String password,
                         String type)

Provide the connection timeout for the underlying connection.

Parameters:

connectionTimeout - time, in milliseconds, to attempt a connection

readTimeout - the read timeout in milliseconds

Method Detail

readFrom

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

Specified by:

readFrom in interface StreamProvider

Throws:

IOException

processURL

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

Throws:

IOException

readFrom

public InputStream readFrom(String spec)
                     throws IOException

Specified by:

readFrom in interface StreamProvider

Throws:

IOException