Class StaggeredRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.infinispan.remoting.transport.AbstractRequest<Address,T>

org.infinispan.remoting.transport.impl.ExclusiveTargetRequest<T>

org.infinispan.remoting.transport.impl.MultiTargetRequest<T>

org.infinispan.remoting.transport.jgroups.StaggeredRequest<T>

All Implemented Interfaces:

Callable<Void>, CompletionStage<T>, Future<T>, Request<Address,T>

public class StaggeredRequest<T>
extends MultiTargetRequest<T>

Since:

9.1

Author:

Dan Berindei

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Field Summary

Fields inherited from class AbstractRequest

repository, requestId, responseCollector

Fields inherited from interface Request

NO_REQUEST_ID

Method Summary

Modifier and Type	Method	Description
protected void	actualOnResponse(Address sender, Response response)
protected void	actualOnTimeout()
void	setTimeout(ScheduledExecutorService timeoutExecutor, long timeout, TimeUnit unit)	Schedule a timeout task on the given executor, and complete the request with a TimeoutException when the task runs.

Methods inherited from class MultiTargetRequest

actualOnView, getTarget, getTargetsSize

Methods inherited from class ExclusiveTargetRequest

onNewView, onResponse, onTimeout

Methods inherited from class AbstractRequest

call, cancel, cancel, complete, completeExceptionally, getRequestId, getTimeoutMs

Methods inherited from class CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, completeAsync, completeAsync, completedFuture, completedStage, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class Object

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

Methods inherited from interface CompletionStage

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, handle, handleAsync, handleAsync, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

Method Details

setTimeout

public void setTimeout(ScheduledExecutorService timeoutExecutor,
 long timeout,
 TimeUnit unit)

Description copied from class: AbstractRequest

Schedule a timeout task on the given executor, and complete the request with a TimeoutException when the task runs. If a timeout task was already registered with this request, it is cancelled.

Overrides:

setTimeout in class AbstractRequest<Address,T>

actualOnResponse

protected void actualOnResponse(Address sender,
 Response response)

Overrides:

actualOnResponse in class MultiTargetRequest<T>

actualOnTimeout

protected void actualOnTimeout()

Overrides:

actualOnTimeout in class MultiTargetRequest<T>