| | |
| | | import static org.opends.server.replication.plugin. |
| | | ReplicationRepairRequestControl.*; |
| | | |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.concurrent.BlockingQueue; |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | import java.util.concurrent.LinkedBlockingQueue; |
| | | |
| | | import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString; |
| | |
| | | { |
| | | private ReplicationServerListener replicationServerListener = null; |
| | | private static Map<DN, LDAPReplicationDomain> domains = |
| | | new HashMap<DN, LDAPReplicationDomain>() ; |
| | | new ConcurrentHashMap<DN, LDAPReplicationDomain>(4) ; |
| | | |
| | | /** |
| | | * The queue of received update messages, to be treated by the ReplayThread |