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 DngetBaseDN()Get the base DN from this ReplServerStartMsg.byte[]getBytes(short protocolVersion)Serializes the PDU using the provided replication protocol version.intgetDegradedStatusThreshold()Get the degraded status threshold value.com.forgerock.opendj.util.HostPortgetHostPort()Get the host port.ReplicationServerIdgetServerId()Get the Server Id.ServerStategetServerState()Get the serverState.booleangetSSLEncryption()Get the SSL encryption value for the server that created the message.voidsetDegradedStatusThreshold(int degradedStatusThreshold)Set the degraded status threshold (For test purpose).StringtoString()-
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: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.
-
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.
-
-