Package org.opends.server.replication.protocol

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

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

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 Details

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

toString

public String toString()

Overrides:

toString in class Object