Package org.infinispan.remoting.transport.jgroups

Class StaggeredRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.infinispan.remoting.transport.AbstractRequest<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
void	onResponse(Address sender, Response response)	Called when a response is received for this response.
protected void	onTimeout()	Called when the timeout task scheduled with AbstractRequest.setTimeout(ScheduledExecutorService, long, TimeUnit) expires.
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

getTarget, getTargetsSize, onNewView

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

call, cancel, cancel, complete, completeExceptionally, getRequestId

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, 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, 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 Detail

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>

onResponse

public void onResponse(Address sender,
                       Response response)

Description copied from interface: Request

Called when a response is received for this response.

Specified by:

onResponse in interface Request<T>

Overrides:

onResponse in class MultiTargetRequest<T>

onTimeout

protected void onTimeout()

Description copied from class: AbstractRequest

Called when the timeout task scheduled with AbstractRequest.setTimeout(ScheduledExecutorService, long, TimeUnit) expires.

Overrides:

onTimeout in class MultiTargetRequest<T>