public class RaftInvocation extends Invocation<CPMember>
Invocation
implementation that realizes an operation invocation on the leader node of the given Raft group.
Internally handles Raft-related exceptions.firstInvocationTimeMillis, op
backupsAcksReceived
Constructor and Description |
---|
RaftInvocation(com.hazelcast.spi.impl.operationservice.impl.Invocation.Context context,
RaftInvocationContext raftInvocationContext,
CPGroupId groupId,
Operation op,
int retryCount,
long retryPauseMillis,
long callTimeoutMillis) |
Modifier and Type | Method and Description |
---|---|
protected void |
notifyThrowable(Throwable cause,
int expectedBackups) |
protected ExceptionAction |
onException(Throwable t) |
protected boolean |
shouldFailOnIndeterminateOperationState() |
complete, completeExceptionally, invoke, invokeAsync, sendResponse, shouldCompleteWithoutBackups, toString
detectAndHandleBackupTimeout, notifyBackupComplete, notifyResponse
public RaftInvocation(com.hazelcast.spi.impl.operationservice.impl.Invocation.Context context, RaftInvocationContext raftInvocationContext, CPGroupId groupId, Operation op, int retryCount, long retryPauseMillis, long callTimeoutMillis)
protected void notifyThrowable(Throwable cause, int expectedBackups)
notifyThrowable
in class Invocation<CPMember>
protected ExceptionAction onException(Throwable t)
protected boolean shouldFailOnIndeterminateOperationState()
shouldFailOnIndeterminateOperationState
in class Invocation<CPMember>
Copyright © 2019 Hazelcast, Inc.. All rights reserved.