Class StaggeredRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.infinispan.remoting.transport.AbstractRequest<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<T>

public class StaggeredRequest<T>
extends MultiTargetRequest<T>

Since:

9.1

Author:

Dan Berindei

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Field Summary

Fields inherited from class org.infinispan.remoting.transport.AbstractRequest

repository, requestId, responseCollector

Fields inherited from interface org.infinispan.remoting.transport.impl.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 org.infinispan.remoting.transport.impl.MultiTargetRequest

actualOnView, getTarget, getTargetsSize

Methods inherited from class org.infinispan.remoting.transport.impl.ExclusiveTargetRequest

onNewView, onResponse, onTimeout

Methods inherited from class org.infinispan.remoting.transport.AbstractRequest

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

Methods inherited from class java.util.concurrent.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 java.lang.Object

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

Methods inherited from interface java.util.concurrent.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<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>