Class 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.
    • 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 class ReplicationMsg
        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 class ReplicationMsg
        Returns:
        if in case of I/O error we should try to send this message again