com.orientechnologies.orient.server.distributed

Class OAsynchDistributedOperation

java.lang.Object

com.orientechnologies.orient.server.distributed.OAsynchDistributedOperation

public class OAsynchDistributedOperation
extends Object

Asynchronous distributed operation.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Constructor Summary

Constructors

Constructor and Description
OAsynchDistributedOperation(String iDatabaseName, Set<String> iClusterNames, Collection<String> iNodes, ORemoteTask iTask, long iMessageId, Object iLocalResult, OCallable<Void,ODistributedRequestId> iAfterRequestCallback, OCallable<Object,OPair<ODistributedRequestId,Object>> iCallback)

Method Summary

Modifier and Type	Method and Description
OCallable<Void,ODistributedRequestId>	getAfterSendCallback()
OCallable<Object,OPair<ODistributedRequestId,Object>>	getCallback()
Set<String>	getClusterNames()
String	getDatabaseName()
Object	getLocalResult()
long	getMessageId()
Collection<String>	getNodes()
ORemoteTask	getTask()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OAsynchDistributedOperation

public OAsynchDistributedOperation(String iDatabaseName,
                                   Set<String> iClusterNames,
                                   Collection<String> iNodes,
                                   ORemoteTask iTask,
                                   long iMessageId,
                                   Object iLocalResult,
                                   OCallable<Void,ODistributedRequestId> iAfterRequestCallback,
                                   OCallable<Object,OPair<ODistributedRequestId,Object>> iCallback)

Method Detail

getClusterNames

public Set<String> getClusterNames()

getNodes

public Collection<String> getNodes()

getTask

public ORemoteTask getTask()

getDatabaseName

public String getDatabaseName()

getCallback

public OCallable<Object,OPair<ODistributedRequestId,Object>> getCallback()

getLocalResult

public Object getLocalResult()

getAfterSendCallback

public OCallable<Void,ODistributedRequestId> getAfterSendCallback()

getMessageId

public long getMessageId()