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 Details

    • 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 Details

    • 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
    • setCustomErrors

      public void setCustomErrors(CustomHttpErrors customErrors)
    • setWriteTimeout

      public void setWriteTimeout(int writeTimeout)
      Parameters:
      writeTimeout - in milliseconds.
    • setHttpHeaders

      public void setHttpHeaders(Map<String,String> httpHeaders)
    • setReadTimeout

      public void setReadTimeout(int readTimeout)
      Parameters:
      readTimeout - in milliseconds.