public class ReplConsumerManager extends Object
Constructor and Description |
---|
ReplConsumerManager(DirectoryService directoryService)
Create a new instance of the producer replication manager.
|
Modifier and Type | Method and Description |
---|---|
void |
addConsumerEntry(ReplicaEventLog replica)
Add a new consumer entry in ou=consumers,ou=system
|
void |
deleteConsumerEntry(ReplicaEventLog replica)
Delete an existing consumer entry from ou=consumers,ou=system
|
List<ReplicaEventLog> |
getReplicaEventLogs()
Get the list of consumers' configuration
|
void |
updateReplicaLastSentCsn(ReplicaEventLog replica)
Store the new CSN sent by the consumer in place of the previous one.
|
public ReplConsumerManager(DirectoryService directoryService) throws Exception
directoryService
- The directoryService instanceException
- if we add an error while creating the configurationpublic void addConsumerEntry(ReplicaEventLog replica) throws Exception
replica
- The added consumer replicaException
- If the addition failedpublic void deleteConsumerEntry(ReplicaEventLog replica) throws org.apache.directory.api.ldap.model.exception.LdapException
replica
- The added consumer replicaorg.apache.directory.api.ldap.model.exception.LdapException
- If the addition failedpublic void updateReplicaLastSentCsn(ReplicaEventLog replica) throws Exception
replica
- The consumer informationsException
- If the update failedpublic List<ReplicaEventLog> getReplicaEventLogs() throws Exception
Exception
- If we had an error while building this listCopyright © 2003–2020 The Apache Software Foundation. All rights reserved.