Uses of Interface
com.orientechnologies.orient.server.distributed.ODistributedResponseManager

Packages that use ODistributedResponseManager

Package	Description
com.orientechnologies.orient.server.distributed
com.orientechnologies.orient.server.distributed.impl

Uses of ODistributedResponseManager in com.orientechnologies.orient.server.distributed

Classes in com.orientechnologies.orient.server.distributed that implement ODistributedResponseManager

Modifier and Type	Class and Description
class	ODistributedResponseManagerImpl Asynchronous response manager.

Methods in com.orientechnologies.orient.server.distributed that return ODistributedResponseManager

Modifier and Type	Method and Description
ODistributedResponseManager	ODistributedResponse.getDistributedResponseManager()
ODistributedResponseManager	ODistributedMessageService.getResponseManager(ODistributedRequestId reqId)

Methods in com.orientechnologies.orient.server.distributed with parameters of type ODistributedResponseManager

Modifier and Type	Method and Description
void	ODistributedMessageService.registerRequest(long id, ODistributedResponseManager currentResponseMgr)
void	ODistributedResponse.setDistributedResponseManager(ODistributedResponseManager distributedResponseManager)

Method parameters in com.orientechnologies.orient.server.distributed with type arguments of type ODistributedResponseManager

Modifier and Type	Method and Description
ODistributedResponse	ODistributedDatabase.send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
ODistributedResponse	ODistributedServerManager.sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodeNames, ORemoteTask iTask, long messageId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback) Sends a distributed request against multiple servers.

Constructors in com.orientechnologies.orient.server.distributed with parameters of type ODistributedResponseManager

Constructor and Description
ODistributedResponse(ODistributedResponseManager msg, ODistributedRequestId iRequestId, String executorNodeName, String senderNodeName, Object payload)

Constructor parameters in com.orientechnologies.orient.server.distributed with type arguments of type ODistributedResponseManager

Constructor and Description
ODistributedResponseManagerImpl(ODistributedServerManager iManager, ODistributedRequest iRequest, Collection<String> expectedResponses, Set<String> iNodesConcurInQuorum, int iTotalExpectedResponses, int iQuorum, boolean iWaitForLocalNode, long iSynchTimeout, long iTotalTimeout, boolean iGroupResponsesByResult, OCallable<Void,ODistributedResponseManager> endCallback)

Uses of ODistributedResponseManager in com.orientechnologies.orient.server.distributed.impl

Classes in com.orientechnologies.orient.server.distributed.impl that implement ODistributedResponseManager

Modifier and Type	Class and Description
class	ONewDistributedResponseManager

Methods in com.orientechnologies.orient.server.distributed.impl that return ODistributedResponseManager

Modifier and Type	Method and Description
ODistributedResponseManager	ODistributedMessageServiceImpl.getResponseManager(ODistributedRequestId reqId)
ODistributedResponseManager	ODistributedDatabaseImpl.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)

Methods in com.orientechnologies.orient.server.distributed.impl with parameters of type ODistributedResponseManager

Modifier and Type	Method and Description
void	ODistributedMessageServiceImpl.registerRequest(long id, ODistributedResponseManager currentResponseMgr)
protected ODistributedResponse	ODistributedDatabaseImpl.waitForResponse(ODistributedRequest iRequest, ODistributedResponseManager currentResponseMgr)

Method parameters in com.orientechnologies.orient.server.distributed.impl with type arguments of type ODistributedResponseManager

Modifier and Type	Method and Description
ODistributedResponseManager	ODistributedDatabaseImpl.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponse	ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
ODistributedResponse	ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	ODistributedAbstractPlugin.sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodes, ORemoteTask iTask, long reqId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
ODistributedResponse	ODistributedAbstractPlugin.sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodes, ORemoteTask iTask, long reqId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback, ODistributedResponseManagerFactory responseManagerFactory)