org.apache.beam.sdk.util

Class RetryHttpRequestInitializer

java.lang.Object

org.apache.beam.sdk.util.RetryHttpRequestInitializer

All Implemented Interfaces:

com.google.api.client.http.HttpRequestInitializer

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 a HttpResponseInterceptor to be applied to the responses.

Constructor Summary

Constructors

Constructor and Description
RetryHttpRequestInitializer()
RetryHttpRequestInitializer(Collection<Integer> additionalIgnoredResponseCodes)
RetryHttpRequestInitializer(Collection<Integer> additionalIgnoredResponseCodes, com.google.api.client.http.HttpResponseInterceptor responseInterceptor)

Method Summary

Modifier and Type	Method and Description
void	initialize(com.google.api.client.http.HttpRequest request)

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(Collection<Integer> additionalIgnoredResponseCodes)

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 Detail

initialize

public void initialize(com.google.api.client.http.HttpRequest request)
                throws IOException

Specified by:

initialize in interface com.google.api.client.http.HttpRequestInitializer

Throws:

IOException