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.CSNgetCSN()Get a CSN with the transmitted change time.booleanisRetryable()Returns if in case of I/O error we should try to send this message again.StringtoString()-
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 DataFormatExceptionCreates 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:ReplicationMsgSerializes 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:
getBytesin 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
nullif the message isn't supported in that protocol version.
-
isRetryable
public boolean isRetryable()
Description copied from class:ReplicationMsgReturns if in case of I/O error we should try to send this message again.- Overrides:
isRetryablein classReplicationMsg- Returns:
- if in case of I/O error we should try to send this message again
-
-