| | |
| | | import java.io.OutputStream; |
| | | |
| | | import org.opends.server.admin.server.ConfigurationChangeListener; |
| | | import org.opends.server.admin.std.meta.MultimasterDomainCfgDefn.*; |
| | | import org.opends.server.admin.std.server.MultimasterDomainCfg; |
| | | import org.opends.server.admin.std.meta.ReplicationDomainCfgDefn.*; |
| | | import org.opends.server.admin.std.server.ReplicationDomainCfg; |
| | | import org.opends.server.api.AlertGenerator; |
| | | import org.opends.server.api.Backend; |
| | | import org.opends.server.api.DirectoryThread; |
| | |
| | | * handle protocol messages from the replicationServer. |
| | | */ |
| | | public class ReplicationDomain extends DirectoryThread |
| | | implements ConfigurationChangeListener<MultimasterDomainCfg>, |
| | | implements ConfigurationChangeListener<ReplicationDomainCfg>, |
| | | AlertGenerator |
| | | { |
| | | /** |
| | |
| | | * @param configuration The configuration of this ReplicationDomain. |
| | | * @throws ConfigException In case of invalid configuration. |
| | | */ |
| | | public ReplicationDomain(MultimasterDomainCfg configuration) |
| | | public ReplicationDomain(ReplicationDomainCfg configuration) |
| | | throws ConfigException |
| | | { |
| | | super("replication flush"); |
| | |
| | | // Read the configuration parameters. |
| | | replicationServers = configuration.getReplicationServer(); |
| | | serverId = (short) configuration.getServerId(); |
| | | baseDN = configuration.getReplicationDN(); |
| | | baseDN = configuration.getBaseDN(); |
| | | maxReceiveQueue = configuration.getMaxReceiveQueue(); |
| | | maxReceiveDelay = (int) configuration.getMaxReceiveDelay(); |
| | | maxSendQueue = configuration.getMaxSendQueue(); |
| | |
| | | * @return true if the configuration is acceptable, false other wise. |
| | | */ |
| | | public static boolean isConfigurationAcceptable( |
| | | MultimasterDomainCfg configuration, List<Message> unacceptableReasons) |
| | | ReplicationDomainCfg configuration, List<Message> unacceptableReasons) |
| | | { |
| | | // Check that there is not already a domain with the same DN |
| | | DN dn = configuration.getReplicationDN(); |
| | | DN dn = configuration.getBaseDN(); |
| | | if (MultimasterReplication.findDomain(dn,null) != null) |
| | | { |
| | | Message message = ERR_SYNC_INVALID_DN.get(); |
| | |
| | | * {@inheritDoc} |
| | | */ |
| | | public ConfigChangeResult applyConfigurationChange( |
| | | MultimasterDomainCfg configuration) |
| | | ReplicationDomainCfg configuration) |
| | | { |
| | | // server id and base dn are readonly. |
| | | // isolationPolicy can be set immediately and will apply |
| | |
| | | * {@inheritDoc} |
| | | */ |
| | | public boolean isConfigurationChangeAcceptable( |
| | | MultimasterDomainCfg configuration, List<Message> unacceptableReasons) |
| | | ReplicationDomainCfg configuration, List<Message> unacceptableReasons) |
| | | { |
| | | return true; |
| | | } |