Class RetryHttpRequestInitializer
java.lang.Object
org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer
- All Implemented Interfaces:
com.google.api.client.http.HttpRequestInitializer
- Direct Known Subclasses:
HttpHealthcareApiClient.AuthenticatedRetryInitializer
public class RetryHttpRequestInitializer
extends Object
implements com.google.api.client.http.HttpRequestInitializer
Implements a request initializer that adds retry handlers to all HttpRequests.
Also can take an HttpResponseInterceptor to be applied to the responses.
-
Constructor Summary
ConstructorsConstructorDescriptionRetryHttpRequestInitializer
(Collection<Integer> additionalIgnoredResponseCodes) RetryHttpRequestInitializer
(Collection<Integer> additionalIgnoredResponseCodes, @Nullable com.google.api.client.http.HttpResponseInterceptor responseInterceptor) -
Method Summary
Modifier and TypeMethodDescriptionvoid
initialize
(com.google.api.client.http.HttpRequest request) void
setCustomErrors
(CustomHttpErrors customErrors) void
setHttpHeaders
(Map<String, String> httpHeaders) void
setReadTimeout
(int readTimeout) void
setWriteTimeout
(int writeTimeout)
-
Constructor Details
-
RetryHttpRequestInitializer
public RetryHttpRequestInitializer() -
RetryHttpRequestInitializer
- Parameters:
additionalIgnoredResponseCodes
- a list of HTTP status codes that should not be logged.
-
RetryHttpRequestInitializer
public RetryHttpRequestInitializer(Collection<Integer> additionalIgnoredResponseCodes, @Nullable com.google.api.client.http.HttpResponseInterceptor responseInterceptor) - Parameters:
additionalIgnoredResponseCodes
- a list of HTTP status codes that should not be logged.responseInterceptor
- HttpResponseInterceptor to be applied on all requests. May be null.
-
-
Method Details
-
initialize
- Specified by:
initialize
in interfacecom.google.api.client.http.HttpRequestInitializer
- Throws:
IOException
-
setCustomErrors
-
setWriteTimeout
public void setWriteTimeout(int writeTimeout) - Parameters:
writeTimeout
- in milliseconds.
-
setHttpHeaders
-
setReadTimeout
public void setReadTimeout(int readTimeout) - Parameters:
readTimeout
- in milliseconds.
-