io.sphere.sdk.client

Class QueueSphereClientDecorator

java.lang.Object

io.sphere.sdk.models.Base

io.sphere.sdk.client.SphereClientDecorator

io.sphere.sdk.client.QueueSphereClientDecorator

All Implemented Interfaces:

SphereClient, AutoCloseable

public final class QueueSphereClientDecorator
extends SphereClientDecorator
implements SphereClient

Decorates a SphereClient to limit the amount of parallel requests which await an answer. If maxParallelRequests are waiting for a response every further request will be added to an unbound queue. Then the next answer will cause that the first request in the queue will be executed.

Method Summary

Modifier and Type	Method and Description
void	close() Shuts down the client to save resources like connections and threads.
<T> CompletionStage<T>	execute(SphereRequest<T> sphereRequest) Executes asynchronously a request to Composable Commerce.
static SphereClient	of(SphereClient delegate, int maxParallelRequests)
static SphereClient	of(SphereClient delegate, int maxParallelRequests, boolean closeUnderlyingClient)

Methods inherited from class io.sphere.sdk.client.SphereClientDecorator

getConfig

Methods inherited from class io.sphere.sdk.models.Base

equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.sphere.sdk.client.SphereClient

getConfig, of, of

Method Detail

execute

public <T> CompletionStage<T> execute(SphereRequest<T> sphereRequest)

Description copied from interface: SphereClient

Executes asynchronously a request to Composable Commerce. By default it does not have a timeout.

Specified by:

execute in interface SphereClient

Overrides:

execute in class SphereClientDecorator

Type Parameters:

T - type of the result for the request

Parameters:

sphereRequest - request to Composable Commerce to perform

Returns:

future monad which can contain the result or an exception

close

public void close()

Description copied from interface: SphereClient

Shuts down the client to save resources like connections and threads.

Specified by:

close in interface SphereClient

Specified by:

close in interface AutoCloseable

Overrides:

close in class SphereClientDecorator

of

public static SphereClient of(SphereClient delegate,
                              int maxParallelRequests,
                              boolean closeUnderlyingClient)

of

public static SphereClient of(SphereClient delegate,
                              int maxParallelRequests)