Class ChangeTimeHeartbeatMsg
- java.lang.Object
-
- org.opends.server.replication.protocol.ReplicationMsg
-
- org.opends.server.replication.protocol.ChangeTimeHeartbeatMsg
-
public final class ChangeTimeHeartbeatMsg extends ReplicationMsg
Class that define messages sent by a replication domain (DS) to the replication server to let the RS know the DS current change time.
-
-
Field Summary
-
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 ChangeTimeHeartbeatMsg(byte[] in)
Creates a message from a provided byte array.ChangeTimeHeartbeatMsg(CSN csn)
Constructor of a Change Time Heartbeat message providing the change time value in a CSN.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]
getBytes(short protocolVersion)
Serializes the PDU using the provided replication protocol version.CSN
getCSN()
Get a CSN with the transmitted change time.boolean
isRetryable()
Returns if in case of I/O error we should try to send this message again.String
toString()
-
Methods inherited from class org.opends.server.replication.protocol.ReplicationMsg
decodeMsg
-
-
-
-
Constructor Detail
-
ChangeTimeHeartbeatMsg
public ChangeTimeHeartbeatMsg(CSN csn)
Constructor of a Change Time Heartbeat message providing the change time value in a CSN.- Parameters:
csn
- The provided CSN.
-
ChangeTimeHeartbeatMsg
public ChangeTimeHeartbeatMsg(byte[] in) throws DataFormatException
Creates a message from a provided byte array.- Parameters:
in
- The provided byte array.- Throws:
DataFormatException
- When an error occurs.
-
-
Method Detail
-
getCSN
public CSN getCSN()
Get a CSN with the transmitted change time.- Returns:
- the CSN
-
getBytes
public byte[] getBytes(short protocolVersion)
Description copied from class:ReplicationMsg
Serializes the PDU using the provided replication protocol version. WARNING: should be overwritten by a PDU (sub class) we want to support older protocol version serialization for.- Specified by:
getBytes
in classReplicationMsg
- Parameters:
protocolVersion
- The protocol version to use for serialization. The version should normally be older than the current one.- Returns:
- The encoded PDU, or
null
if the message isn't supported in that protocol version.
-
isRetryable
public boolean isRetryable()
Description copied from class:ReplicationMsg
Returns if in case of I/O error we should try to send this message again.- Overrides:
isRetryable
in classReplicationMsg
- Returns:
- if in case of I/O error we should try to send this message again
-
-