public abstract class BaseInvocation extends Object
Modifier and Type | Field and Description |
---|---|
protected int |
backupsAcksReceived
Number of backups acks received.
|
Constructor and Description |
---|
BaseInvocation() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
complete(Object value) |
protected abstract void |
completeExceptionally(Throwable t) |
boolean |
detectAndHandleBackupTimeout(long timeoutMillis)
gets called from the Clean resources task
|
void |
notifyBackupComplete() |
protected void |
notifyResponse(Object response,
int expectedBackups) |
protected abstract boolean |
shouldCompleteWithoutBackups() |
protected abstract boolean |
shouldFailOnIndeterminateOperationState() |
protected volatile int backupsAcksReceived
public void notifyBackupComplete()
protected void notifyResponse(Object response, int expectedBackups)
response
- return true if invocation completedpublic boolean detectAndHandleBackupTimeout(long timeoutMillis)
timeoutMillis
- timeout value to wait for backups after the response receivedprotected abstract boolean shouldCompleteWithoutBackups()
protected abstract void complete(Object value)
protected abstract void completeExceptionally(Throwable t)
protected abstract boolean shouldFailOnIndeterminateOperationState()
Copyright © 2019 Hazelcast, Inc.. All rights reserved.