Package com.orientechnologies.orient.distributed.context.coordination.message.operation

Class ODeclareDbMessage

java.lang.Object

com.orientechnologies.orient.distributed.context.coordination.message.operation.ODeclareDbMessage

All Implemented Interfaces:

OOperationMessage

public class ODeclareDbMessage
extends Object
implements OOperationMessage

Constructor Summary

Constructors

Constructor	Description
ODeclareDbMessage(String name, ODatabaseId id, Set<ONodeId> partecipants, int minimumQuorum)

Method Summary

Modifier and Type	Method	Description
void	apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
ODatabaseId	getId()
int	getMinimumQuorum()
String	getName()
Set<ONodeId>	getPartecipants()
short	getType()
static ODeclareDbMessage	readNetwork(DataInput input)
void	serialize(DataOutput out)
Optional<OAcceptResult>	validate(OrientDBDistributed ctx, OTransactionIdPromise promise)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.distributed.context.coordination.message.operation.OOperationMessage

writeNetwork

Constructor Details

ODeclareDbMessage

public ODeclareDbMessage(String name,
 ODatabaseId id,
 Set<ONodeId> partecipants,
 int minimumQuorum)

Method Details

validate

public Optional<OAcceptResult> validate(OrientDBDistributed ctx,
 OTransactionIdPromise promise)

Specified by:

validate in interface OOperationMessage

apply

public void apply(OrientDBDistributed ctx,
 OTransactionIdPromise promise)

Specified by:

apply in interface OOperationMessage

cancel

public void cancel(OrientDBDistributed ctx,
 OTransactionIdPromise promise)

Specified by:

cancel in interface OOperationMessage

serialize

public void serialize(DataOutput out)
               throws IOException

Specified by:

serialize in interface OOperationMessage

Throws:

IOException

getType

public short getType()

Specified by:

getType in interface OOperationMessage

readNetwork

public static ODeclareDbMessage readNetwork(DataInput input)
                                     throws IOException

Throws:

IOException

getId

public ODatabaseId getId()

getName

public String getName()

getPartecipants

public Set<ONodeId> getPartecipants()

getMinimumQuorum

public int getMinimumQuorum()