Package com.aventstack.chaintest.http

Class HttpRetryHandler

java.lang.Object

com.aventstack.chaintest.http.HttpRetryHandler

public class HttpRetryHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_RETRY_ATTEMPTS
static final long	RETRY_INTERVAL

Constructor Summary

Constructors

Constructor	Description
HttpRetryHandler(ChainTestApiClient client, int maxRetryAttempts, long retryIntervalMs, boolean throwAfterMaxRetryAttempts)
HttpRetryHandler(ChainTestApiClient client, Map<String,String> config)

Method Summary

Modifier and Type	Method	Description
Map<String,WrappedResponseAsync<Test>>	sendWithRetries(Map<String,WrappedResponseAsync<Test>> collection)
<T extends ChainTestEntity> HttpResponse<T>	trySend(T entity, Class<T> clazz, HttpMethod httpMethod)
<T extends ChainTestEntity> HttpResponse<T>	trySend(T entity, Class<T> clazz, HttpMethod httpMethod, int maxRetryAttempts)

Methods inherited from class java.lang.Object

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

Field Details

MAX_RETRY_ATTEMPTS

public static final int MAX_RETRY_ATTEMPTS

See Also:

• Constant Field Values

RETRY_INTERVAL

public static final long RETRY_INTERVAL

See Also:

• Constant Field Values

Constructor Details

HttpRetryHandler

public HttpRetryHandler(ChainTestApiClient client,
 Map<String,String> config)

HttpRetryHandler

public HttpRetryHandler(ChainTestApiClient client,
 int maxRetryAttempts,
 long retryIntervalMs,
 boolean throwAfterMaxRetryAttempts)

Method Details

trySend

public <T extends ChainTestEntity> HttpResponse<T> trySend(T entity,
 Class<T> clazz,
 HttpMethod httpMethod,
 int maxRetryAttempts)
                                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

trySend

public <T extends ChainTestEntity> HttpResponse<T> trySend(T entity,
 Class<T> clazz,
 HttpMethod httpMethod)
                                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

sendWithRetries

public Map<String,WrappedResponseAsync<Test>> sendWithRetries(Map<String,WrappedResponseAsync<Test>> collection)