Interface Request<S,T>

All Superinterfaces:

CompletionStage<T>

All Known Implementing Classes:

AbstractRequest, ExclusiveTargetRequest, MultiTargetRequest, SingleSiteRequest, SingleTargetRequest, StaggeredRequest

public interface Request<S,T>
extends CompletionStage<T>

A remote command invocation request.

Since:

9.1

Author:

Dan Berindei

Field Summary

Fields

Modifier and Type	Field	Description
static final long	NO_REQUEST_ID

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)	Cancels the current request if it is not already completed.
void	cancel(Exception cancellationException)	Complete the request with an exception and release its resources.
long	getRequestId()
boolean	onNewView(Set<Address> members)	Called when the node received a new cluster view.
void	onResponse(S sender, Response response)	Called when a response is received for this response.

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

Field Details

NO_REQUEST_ID

static final long NO_REQUEST_ID

See Also:

• Constant Field Values

Method Details

getRequestId

long getRequestId()

Returns:

The unique request id.

onResponse

void onResponse(S sender,
 Response response)

Called when a response is received for this response.

onNewView

boolean onNewView(Set<Address> members)

Called when the node received a new cluster view.

Returns:

true if any of the request targets is not in the view. This value should only be used before the request was actually submitted.

cancel

void cancel(Exception cancellationException)

Complete the request with an exception and release its resources.

cancel

boolean cancel(boolean mayInterruptIfRunning)

Cancels the current request if it is not already completed.

Parameters:

mayInterruptIfRunning - allow to interrupt running thread.

Returns:

true, if this task was cancelled.

See Also:

• CompletableFuture.cancel(boolean)