io.sphere.sdk.retry

Interface AsyncRetrySupervisor

All Superinterfaces:

AutoCloseable

public interface AsyncRetrySupervisor
extends AutoCloseable

Internal API: A service that can wrap other service calls to make them retryable.

This class is internally used in RetrySphereClientDecorator:

import io.sphere.sdk.client.RetrySphereClientDecorator;

import io.sphere.sdk.client.SphereClient;

import io.sphere.sdk.retry.RetryAction;

import io.sphere.sdk.retry.RetryPredicate;

import io.sphere.sdk.retry.RetryRule;

import java.time.Duration;

import java.util.List;

import static io.sphere.sdk.http.HttpStatusCode.BAD_GATEWAY_502;

import static io.sphere.sdk.http.HttpStatusCode.GATEWAY_TIMEOUT_504;

import static io.sphere.sdk.http.HttpStatusCode.SERVICE_UNAVAILABLE_503;

import static java.util.Collections.singletonList;

public class RetryBadGatewayExample {
    public static SphereClient ofRetry(final SphereClient delegate) {
        final int maxAttempts = 5;
        final List<RetryRule> retryRules = singletonList(RetryRule.of(
                RetryPredicate.ofMatchingStatusCodes(BAD_GATEWAY_502, SERVICE_UNAVAILABLE_503, GATEWAY_TIMEOUT_504),
                RetryAction.ofScheduledRetry(maxAttempts, context -> Duration.ofSeconds(context.getAttempt() * 2)))
        );
        return RetrySphereClientDecorator.of(delegate, retryRules);
    }
}
See the test code.

Method Summary

Modifier and Type	Method and Description
void	close()
static AsyncRetrySupervisor	of(List<RetryRule> retryRules)
<P,R> CompletionStage<R>	supervise(AutoCloseable service, Function<P,CompletionStage<R>> f, P parameterObject)

Method Detail

supervise

<P,R> CompletionStage<R> supervise(AutoCloseable service,
                                   Function<P,CompletionStage<R>> f,
                                   @Nullable
                                   P parameterObject)

close

void close()

Specified by:

close in interface AutoCloseable

of

static AsyncRetrySupervisor of(List<RetryRule> retryRules)