| | |
| | | */ |
| | | package org.opends.server.replication.server; |
| | | |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.types.Attributes.*; |
| | | import static org.opends.server.util.StaticUtils.*; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Set; |
| | |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.InitializationException; |
| | | |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.types.Attributes.*; |
| | | import static org.opends.server.util.StaticUtils.*; |
| | | |
| | | /** |
| | | * This class implements a buffering/producer/consumer mechanism of |
| | | * replication changes (UpdateMsg) used inside the replication server. |
| | |
| | | } |
| | | |
| | | /** |
| | | * Get the baseDN for this handler as a String. |
| | | * |
| | | * @return The name of the baseDN. |
| | | */ |
| | | protected String getBaseDNString() |
| | | { |
| | | return baseDN.toString(); |
| | | } |
| | | |
| | | /** |
| | | * Increase the counter of updates received from the server. |
| | | */ |
| | | void incrementInCount() |