
public interface ODistributedResponseManager
| Modifier and Type | Method and Description |
|---|---|
void |
cancel() |
boolean |
collectResponse(ODistributedResponse response) |
String |
getDatabaseName() |
Set<String> |
getExpectedNodes() |
ODistributedResponse |
getFinalResponse() |
default Object |
getGenericFinalResponse() |
ODistributedRequestId |
getMessageId() |
List<String> |
getMissingNodes() |
int |
getQuorum() |
ODistributedRequest |
getRequest() |
List<String> |
getRespondingNodes() |
long |
getSentOn() |
Set<String> |
getServersWithoutFollowup() |
long |
getSynchTimeout() |
boolean |
isFinished() |
void |
removeServerBecauseUnreachable(String node) |
boolean |
setLocalResult(String localNodeName,
Object localResult) |
void |
timeout() |
boolean |
waitForSynchronousResponses() |
default Object getGenericFinalResponse()
ODistributedResponse getFinalResponse()
void removeServerBecauseUnreachable(String node)
boolean waitForSynchronousResponses()
throws InterruptedException
InterruptedExceptionlong getSynchTimeout()
void cancel()
ODistributedRequestId getMessageId()
ODistributedRequest getRequest()
int getQuorum()
boolean collectResponse(ODistributedResponse response)
void timeout()
long getSentOn()
String getDatabaseName()
boolean isFinished()
Copyright © 2009–2025 OrientDB. All rights reserved.