| | |
| | | */ |
| | | public void publishHeartbeat(DN baseDN, CSN heartbeatCSN) |
| | | { |
| | | if (MultimasterReplication.isECLDisabledDomain(baseDN)) |
| | | if (!isECLEnabledDomain(baseDN)) |
| | | { |
| | | return; |
| | | } |
| | |
| | | public void publishUpdateMsg(DN baseDN, UpdateMsg updateMsg) |
| | | throws ChangelogException |
| | | { |
| | | if (MultimasterReplication.isECLDisabledDomain(baseDN)) |
| | | if (!isECLEnabledDomain(baseDN)) |
| | | { |
| | | return; |
| | | } |
| | |
| | | } |
| | | |
| | | /** |
| | | * Returns whether the provided baseDN represents a replication domain enabled |
| | | * for the external changelog. |
| | | * <p> |
| | | * This method is a test seam that break the dependency on a static method. |
| | | * |
| | | * @param baseDN |
| | | * the replication domain to check |
| | | * @return true if the provided baseDN is enabled for the external changelog, |
| | | * false if the provided baseDN is disabled for the external changelog |
| | | * or unknown to multimaster replication. |
| | | */ |
| | | protected boolean isECLEnabledDomain(DN baseDN) |
| | | { |
| | | return MultimasterReplication.isECLEnabledDomain(baseDN); |
| | | } |
| | | |
| | | /** |
| | | * Returns the last time each serverId was seen alive for the specified |
| | | * replication domain. |
| | | * |
| | |
| | | : changelogState.getDomainToServerIds().entrySet()) |
| | | { |
| | | final DN baseDN = entry.getKey(); |
| | | if (!isECLEnabledDomain(baseDN)) |
| | | { |
| | | continue; |
| | | } |
| | | |
| | | for (Integer serverId : entry.getValue()) |
| | | { |
| | | final CSN csn = mediumConsistencyRUV.getCSN(baseDN, serverId); |