Class ReplServerStartMsg
- java.lang.Object
-
- org.opends.server.replication.protocol.ReplicationMsg
-
- org.opends.server.replication.protocol.StartMsg
-
- org.opends.server.replication.protocol.ReplServerStartMsg
-
public final class ReplServerStartMsg extends StartMsg
Message sent by a replication server to another replication server at Startup.
-
-
Field Summary
-
Fields inherited from class org.opends.server.replication.protocol.StartMsg
generationId, groupId, MAX_WINDOW_SIZE, protocolVersion
-
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 ReplServerStartMsg(ReplicationServerId rsId, com.forgerock.opendj.util.HostPort rsHostPort, Dn baseDN, ServerState serverState, long generationId, boolean sslEncryption, com.forgerock.opendj.discovery.GroupId groupId, int degradedStatusThreshold)
Create a ReplServerStartMsg.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Dn
getBaseDN()
Get the base DN from this ReplServerStartMsg.byte[]
getBytes(short protocolVersion)
Serializes the PDU using the provided replication protocol version.int
getDegradedStatusThreshold()
Get the degraded status threshold value.com.forgerock.opendj.util.HostPort
getHostPort()
Get the host port.ReplicationServerId
getServerId()
Get the Server Id.ServerState
getServerState()
Get the serverState.boolean
getSSLEncryption()
Get the SSL encryption value for the server that created the message.void
setDegradedStatusThreshold(int degradedStatusThreshold)
Set the degraded status threshold (For test purpose).String
toString()
-
Methods inherited from class org.opends.server.replication.protocol.StartMsg
getGenerationId, getGroupId, getVersion, setGroupId
-
Methods inherited from class org.opends.server.replication.protocol.ReplicationMsg
decodeMsg, isRetryable
-
-
-
-
Constructor Detail
-
ReplServerStartMsg
public ReplServerStartMsg(ReplicationServerId rsId, com.forgerock.opendj.util.HostPort rsHostPort, Dn baseDN, ServerState serverState, long generationId, boolean sslEncryption, com.forgerock.opendj.discovery.GroupId groupId, int degradedStatusThreshold)
Create a ReplServerStartMsg.- Parameters:
rsId
- replication server idrsHostPort
- replication server host portbaseDN
- base DN for which the ReplServerStartMsg is created.serverState
- our ServerState for this baseDN.generationId
- The generationId for this server.sslEncryption
- Whether to continue using SSL to encrypt messages after the start messages have been exchanged.groupId
- The group id of the RSdegradedStatusThreshold
- The degraded status threshold
-
-
Method Detail
-
getServerId
public ReplicationServerId getServerId()
Get the Server Id.- Returns:
- the server id
-
getHostPort
public com.forgerock.opendj.util.HostPort getHostPort()
Get the host port.- Returns:
- the host port
-
getBaseDN
public Dn getBaseDN()
Get the base DN from this ReplServerStartMsg.- Returns:
- the base DN from this ReplServerStartMsg.
-
getServerState
public ServerState getServerState()
Get the serverState.- Returns:
- Returns the serverState.
-
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.
-
getSSLEncryption
public boolean getSSLEncryption()
Get the SSL encryption value for the server that created the message.- Returns:
- The SSL encryption value for the server that created the message.
-
getDegradedStatusThreshold
public int getDegradedStatusThreshold()
Get the degraded status threshold value.- Returns:
- The degraded status threshold value.
-
setDegradedStatusThreshold
public void setDegradedStatusThreshold(int degradedStatusThreshold)
Set the degraded status threshold (For test purpose).- Parameters:
degradedStatusThreshold
- The degraded status threshold to set.
-
-