Class InitializationMsg
- java.lang.Object
-
- org.opends.server.replication.protocol.ReplicationMsg
-
- org.opends.server.replication.protocol.InitializationMsg
-
- Direct Known Subclasses:
DoneMsg
,EntryMsg
,ErrorMsg
,InitializeRcvAckMsg
,InitializeRequestMsg
,InitializeTargetMsg
public abstract class InitializationMsg extends ReplicationMsg
This is an abstract class of messages of the replication protocol for message that needs to contain information about the server that send them and the destination servers to which they should be sent.Initialization messages are used when initializing a new replica from an existing replica: total update messages are sent across the topology from the source replica to the target replica, possibly traversing one or two replication servers in the process (e.g. DS1 -> RS1 -> RS2 -> DS2). For this reason we consider them "routable".
Sender of an initialization message can be a DS or a RS (e.g, in case of Error message). Destination of an initialization message is always a DS.
-
-
Field Summary
Fields Modifier and Type Field Description protected ReplicaId
destination
The destination server or servers of this message.protected ServerId<?>
senderId
The serverID of the server that sends this message.-
Fields inherited from class org.opends.server.replication.protocol.ReplicationMsg
COMPACT_MASK, COMPACT_TYPE_ADD, COMPACT_TYPE_DELETE, COMPACT_TYPE_MODIFY, COMPACT_TYPE_MODIFY_DN, COMPACT_TYPE_REPLICA_OFFLINE, MSG_TYPE_DISK_ENCODING
-
-
Constructor Summary
Constructors Constructor Description InitializationMsg()
Creates an initialization message.InitializationMsg(ServerId<?> sender, ReplicaId destination)
Creates an initialization message.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ReplicaId
getDestination()
Get the destination.ServerId<?>
getSenderID()
Get the server ID of the server that sent this message.String
toString()
-
Methods inherited from class org.opends.server.replication.protocol.ReplicationMsg
decodeMsg, getBytes, isRetryable
-
-