org.opendaylight.controller.cluster.datastore.messages

Class ReadyLocalTransaction

java.lang.Object

org.opendaylight.controller.cluster.datastore.messages.ReadyLocalTransaction

public final class ReadyLocalTransaction
extends Object

Message notifying the shard leader to apply modifications which have been prepared locally against its DataTree. This message is not directly serializable, simply because the leader and sender need to be on the same system. When it needs to be sent out to a remote system, it needs to be intercepted by ReadyLocalTransactionSerializer and turned into BatchedModifications.

Constructor Summary

Constructors

Constructor and Description
ReadyLocalTransaction(TransactionIdentifier transactionId, org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification modification, boolean doCommitOnReady, Optional<SortedSet<String>> participatingShardNames)

Method Summary

Modifier and Type	Method and Description
org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification	getModification()
Optional<SortedSet<String>>	getParticipatingShardNames()
short	getRemoteVersion()
TransactionIdentifier	getTransactionId()
boolean	isDoCommitOnReady()
void	setRemoteVersion(short remoteVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadyLocalTransaction

public ReadyLocalTransaction(TransactionIdentifier transactionId,
                             org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification modification,
                             boolean doCommitOnReady,
                             Optional<SortedSet<String>> participatingShardNames)

Method Detail

getTransactionId

public TransactionIdentifier getTransactionId()

getModification

public org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification getModification()

isDoCommitOnReady

public boolean isDoCommitOnReady()

getRemoteVersion

public short getRemoteVersion()

setRemoteVersion

public void setRemoteVersion(short remoteVersion)

getParticipatingShardNames

public Optional<SortedSet<String>> getParticipatingShardNames()