ODistributedResponseManager (OrientDB 3.0.44 API)

All Known Implementing Classes:

ODistributedResponseManagerImpl, ONewDistributedResponseManager
```
public interface ODistributedResponseManager
```

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`boolean`	`addFollowupToServer(String node)`
`void`	`cancel()`
`boolean`	`collectResponse(ODistributedResponse response)`
`boolean`	`executeInLock(OCallable<Boolean,ODistributedResponseManager> oCallable)`
`Collection<String>`	`getConflictServers()`
`String`	`getDatabaseName()`
`Set<String>`	`getExpectedNodes()`
`ODistributedResponse`	`getFinalResponse()`
`default Object`	`getGenericFinalResponse()`
`ODistributedRequestId`	`getMessageId()`
`List<String>`	`getMissingNodes()`
`int`	`getQuorum()`
`ODistributedResponse`	`getQuorumResponse()`
`ODistributedRequest`	`getRequest()`
`List<String>`	`getRespondingNodes()`
`Object`	`getResponseFromServer(String server)`
`long`	`getSentOn()`
`Set<String>`	`getServersWithoutFollowup()`
`long`	`getSynchTimeout()`
`boolean`	`isFinished()`
`boolean`	`isSynchronousWaiting()`
`void`	`removeServerBecauseUnreachable(String node)`
`boolean`	`setLocalResult(String localNodeName, Object localResult)`
`void`	`timeout()`
`boolean`	`waitForSynchronousResponses()`

Method Detail

setLocalResult

boolean setLocalResult(String localNodeName,
                       Object localResult)

getGenericFinalResponse

default Object getGenericFinalResponse()

getFinalResponse

ODistributedResponse getFinalResponse()

removeServerBecauseUnreachable

void removeServerBecauseUnreachable(String node)

waitForSynchronousResponses

boolean waitForSynchronousResponses()
                             throws InterruptedException

Throws:: InterruptedException

getSynchTimeout
```
long getSynchTimeout()
```

cancel
```
void cancel()
```

getExpectedNodes
```
Set<String> getExpectedNodes()
```

getRespondingNodes
```
List<String> getRespondingNodes()
```

getConflictServers

Collection<String> getConflictServers()

getServersWithoutFollowup

Set<String> getServersWithoutFollowup()

addFollowupToServer

boolean addFollowupToServer(String node)

isSynchronousWaiting
```
boolean isSynchronousWaiting()
```

getQuorumResponse

ODistributedResponse getQuorumResponse()

getMessageId
```
ODistributedRequestId getMessageId()
```

getRequest
```
ODistributedRequest getRequest()
```

getResponseFromServer

Object getResponseFromServer(String server)

getQuorum
```
int getQuorum()
```

executeInLock

boolean executeInLock(OCallable<Boolean,ODistributedResponseManager> oCallable)

collectResponse

boolean collectResponse(ODistributedResponse response)

timeout
```
void timeout()
```

getSentOn
```
long getSentOn()
```

getMissingNodes
```
List<String> getMissingNodes()
```

getDatabaseName
```
String getDatabaseName()
```

isFinished
```
boolean isFinished()
```

Interface ODistributedResponseManager

Method Summary

Method Detail

setLocalResult

getGenericFinalResponse

getFinalResponse

removeServerBecauseUnreachable

waitForSynchronousResponses

getSynchTimeout

cancel

getExpectedNodes

getRespondingNodes

getConflictServers

getServersWithoutFollowup

addFollowupToServer

isSynchronousWaiting

getQuorumResponse

getMessageId

getRequest

getResponseFromServer

getQuorum

executeInLock

collectResponse

timeout

getSentOn

getMissingNodes

getDatabaseName

isFinished