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
InterruptedException
long getSynchTimeout()
void cancel()
ODistributedRequestId getMessageId()
ODistributedRequest getRequest()
int getQuorum()
boolean collectResponse(ODistributedResponse response)
void timeout()
long getSentOn()
String getDatabaseName()
boolean isFinished()
Copyright © 2009–2020 OrientDB. All rights reserved.