| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.replication.plugin; |
| | | |
| | |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.concurrent.BlockingQueue; |
| | | import java.util.concurrent.LinkedBlockingQueue; |
| | | |
| | | import org.opends.messages.Message; |
| | |
| | | } |
| | | |
| | | /** |
| | | * Creates a new domain from its configEntry, do the |
| | | * necessary initialization and starts it so that it is |
| | | * fully operational when this method returns. |
| | | * |
| | | * @param configuration The entry with the configuration of this domain. |
| | | * @param queue The BlockingQueue that this domain will use. |
| | | * |
| | | * @return The domain created. |
| | | * |
| | | * @throws ConfigException When the configuration is not valid. |
| | | */ |
| | | public static LDAPReplicationDomain createNewDomain( |
| | | ReplicationDomainCfg configuration, |
| | | BlockingQueue<UpdateToReplay> queue) |
| | | throws ConfigException |
| | | { |
| | | LDAPReplicationDomain domain; |
| | | domain = new LDAPReplicationDomain(configuration, queue); |
| | | |
| | | domains.put(domain.getBaseDN(), domain); |
| | | return domain; |
| | | } |
| | | |
| | | /** |
| | | * Deletes a domain. |
| | | * @param dn : the base DN of the domain to delete. |
| | | */ |