org.apache.beam.sdk.extensions.gcp.util

Class RetryHttpRequestInitializer

java.lang.Object

org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer

All Implemented Interfaces:

HttpRequestInitializer

public class RetryHttpRequestInitializer
extends java.lang.Object
implements HttpRequestInitializer

Implements a request initializer that adds retry handlers to all HttpRequests.

Also can take a HttpResponseInterceptor to be applied to the responses.

Constructor Summary

Constructors

Constructor and Description
RetryHttpRequestInitializer()
RetryHttpRequestInitializer(java.util.Collection<java.lang.Integer> additionalIgnoredResponseCodes)
RetryHttpRequestInitializer(java.util.Collection<java.lang.Integer> additionalIgnoredResponseCodes, HttpResponseInterceptor responseInterceptor)

Method Summary

Modifier and Type	Method and Description
void	initialize(HttpRequest request)
void	setCustomErrors(CustomHttpErrors customErrors)
void	setWriteTimeout(int writeTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryHttpRequestInitializer

public RetryHttpRequestInitializer()

RetryHttpRequestInitializer

public RetryHttpRequestInitializer(java.util.Collection<java.lang.Integer> additionalIgnoredResponseCodes)

Parameters:

additionalIgnoredResponseCodes - a list of HTTP status codes that should not be logged.

RetryHttpRequestInitializer

public RetryHttpRequestInitializer(java.util.Collection<java.lang.Integer> additionalIgnoredResponseCodes,
                                   @Nullable
                                   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 Detail

initialize

public void initialize(HttpRequest request)
                throws java.io.IOException

Specified by:

initialize in interface HttpRequestInitializer

Throws:

java.io.IOException

setCustomErrors

public void setCustomErrors(CustomHttpErrors customErrors)

setWriteTimeout

public void setWriteTimeout(int writeTimeout)