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

Class OEstablishTopology

java.lang.Object

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

All Implemented Interfaces:

OOperationMessage

public class OEstablishTopology
extends Object
implements OOperationMessage

Constructor Summary

Constructors

Constructor	Description
OEstablishTopology(OGroupId groupId, Set<ONodeId> candidates)

Method Summary

Modifier and Type	Method	Description
void	apply(OOperationContext ctx, OTransactionIdPromise promise)
void	cancel(OOperationContext ctx, OTransactionIdPromise promise)
Set<ONodeId>	getCandidates()
OGroupId	getGroupId()
short	getType()
static OEstablishTopology	readNetwork(DataInput input)
void	serialize(DataOutput out)
String	toString()
Optional<OAcceptResult>	validate(OOperationContext ctx, OTransactionIdPromise promise)

Methods inherited from class java.lang.Object

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

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

writeNetwork

Constructor Details

OEstablishTopology

public OEstablishTopology(OGroupId groupId,
 Set<ONodeId> candidates)

Method Details

apply

public void apply(OOperationContext ctx,
 OTransactionIdPromise promise)

Specified by:

apply in interface OOperationMessage

validate

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

Specified by:

validate in interface OOperationMessage

cancel

public void cancel(OOperationContext ctx,
 OTransactionIdPromise promise)

Specified by:

cancel in interface OOperationMessage

readNetwork

public static OEstablishTopology readNetwork(DataInput input)
                                      throws IOException

Throws:

IOException

getType

public short getType()

Specified by:

getType in interface OOperationMessage

serialize

public void serialize(DataOutput out)
               throws IOException

Specified by:

serialize in interface OOperationMessage

Throws:

IOException

getCandidates

public Set<ONodeId> getCandidates()

getGroupId

public OGroupId getGroupId()

toString

public String toString()

Overrides:

toString in class Object