| | |
| | | import org.forgerock.i18n.LocalizableMessage; |
| | | import org.forgerock.i18n.LocalizableMessageBuilder; |
| | | import org.forgerock.i18n.slf4j.LocalizedLogger; |
| | | import org.forgerock.opendj.ldap.ResultCode; |
| | | import org.opends.server.admin.std.server.MonitorProviderCfg; |
| | | import org.opends.server.api.MonitorProvider; |
| | | import org.opends.server.core.DirectoryServer; |
| | |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.HostPort; |
| | | import org.forgerock.opendj.ldap.ResultCode; |
| | | |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.replication.common.ServerStatus.*; |
| | |
| | | // any other failure on the connection. |
| | | |
| | | // FIXME: why do we log for RSs but not DSs? |
| | | logger.error(ERR_CHANGELOG_ERROR_SENDING_MSG, msg.getValue() |
| | | .getDestination()); |
| | | logger.traceException(e); |
| | | logger.error(ERR_CHANGELOG_ERROR_SENDING_MSG, msg.getValue().getDestination()); |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | private void sendPendingChangeTimeHeartbeatMsgs(PendingStatusMessages pendingMsgs) |
| | | { |
| | | for (ChangeTimeHeartbeatMsg pendingHeartbeat : pendingMsgs.pendingHeartbeats |
| | | .values()) |
| | | for (ChangeTimeHeartbeatMsg pendingHeartbeat : pendingMsgs.pendingHeartbeats.values()) |
| | | { |
| | | for (ReplicationServerHandler rsHandler : connectedRSs.values()) |
| | | { |