Package com.orientechnologies.orient.distributed.context

Class OPromisedDistributedOpsImpl

java.lang.Object

com.orientechnologies.orient.distributed.context.OPromisedDistributedOpsImpl

All Implemented Interfaces:

OPromisedDistributedOps

public class OPromisedDistributedOpsImpl
extends Object
implements OPromisedDistributedOps

Constructor Summary

Constructors

Constructor	Description
OPromisedDistributedOpsImpl()

Method Summary

Modifier and Type	Method	Description
void	addNotPromised(ODistributedMessage message)
void	addPromised(ODistributedMessage message)
ODistributedMessage	getNotPromised(OTransactionIdPromise promise)
Optional<Map<OTransactionId,ODistributedMessage>>	getPromised(ONodeId node)
ODistributedMessage	getPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	removeNotPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	removePromised(OTransactionIdPromise promise)

Methods inherited from class java.lang.Object

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

Constructor Details

OPromisedDistributedOpsImpl

public OPromisedDistributedOpsImpl()

Method Details

addPromised

public void addPromised(ODistributedMessage message)

Specified by:

addPromised in interface OPromisedDistributedOps

getPromised

public ODistributedMessage getPromised(OTransactionIdPromise promise)

Specified by:

getPromised in interface OPromisedDistributedOps

removePromised

public Optional<ODistributedMessage> removePromised(OTransactionIdPromise promise)

Specified by:

removePromised in interface OPromisedDistributedOps

addNotPromised

public void addNotPromised(ODistributedMessage message)

Specified by:

addNotPromised in interface OPromisedDistributedOps

getNotPromised

public ODistributedMessage getNotPromised(OTransactionIdPromise promise)

Specified by:

getNotPromised in interface OPromisedDistributedOps

removeNotPromised

public Optional<ODistributedMessage> removeNotPromised(OTransactionIdPromise promise)

Specified by:

removeNotPromised in interface OPromisedDistributedOps

getPromised

public Optional<Map<OTransactionId,ODistributedMessage>> getPromised(ONodeId node)

Specified by:

getPromised in interface OPromisedDistributedOps