Uses of Class
org.opends.server.replication.protocol.UpdateMsg
-
Packages that use UpdateMsg Package Description org.opends.server.replication.plugin This package contains the part of the Multi-master replication code that works on the Directory Server side.org.opends.server.replication.protocol This package contains the code used by the replication server and by the code running on the Directory Server side to exchange their information.org.opends.server.replication.server This package contains the code for the Replication Server part of the Multimaster replication feature.org.opends.server.replication.server.changelog.api This package contains the API for the changelog database.org.opends.server.replication.server.changelog.file This package contains a file-based log implementation for the changelog database API.org.opends.server.replication.service This package contains the generic of the Multi-Master replication code that works on the Directory Server side. -
-
Uses of UpdateMsg in org.opends.server.replication.plugin
Methods in org.opends.server.replication.plugin with parameters of type UpdateMsg Modifier and Type Method Description voidLDAPReplicationDomain. dispatchUpdateForReplay(UpdateMsg updateMsg)The listener thread takes care of processing dependencies between messages viaReplicationDomain.dispatchUpdateForReplay(UpdateMsg), dispatching updates to the replay threads. -
Uses of UpdateMsg in org.opends.server.replication.protocol
Subclasses of UpdateMsg in org.opends.server.replication.protocol Modifier and Type Class Description classAddMsgThis class is used to exchange Add operation between LDAP servers and replication servers.classDeleteMsgObject used when sending delete information to replication servers.classLDAPUpdateMsgAbstract class that must be extended to define a message used for sending Updates between servers.classModifyCommonMsgThis class holds every common code for the modify messages (mod, moddn).classModifyDNMsgMessage used to send Modify DN information.classModifyMsgMessage used to send Modify information.classReplicaOfflineMsgClass that define messages sent by a replica (DS) to the replication server (RS) to let the RS know the date at which a replica went offline.Methods in org.opends.server.replication.protocol that return types with arguments of type UpdateMsg Modifier and Type Method Description org.reactivestreams.Publisher<UpdateMsg>Session. writer(Flowable<UpdateMsg> upstream)Returns aPublisherthat: writes update messages to the remote server with back-pressure support and publishes in return each written message.Methods in org.opends.server.replication.protocol with parameters of type UpdateMsg Modifier and Type Method Description intUpdateMsg. compareTo(UpdateMsg msg)Method parameters in org.opends.server.replication.protocol with type arguments of type UpdateMsg Modifier and Type Method Description org.reactivestreams.Publisher<UpdateMsg>Session. writer(Flowable<UpdateMsg> upstream)Returns aPublisherthat: writes update messages to the remote server with back-pressure support and publishes in return each written message. -
Uses of UpdateMsg in org.opends.server.replication.server
Methods in org.opends.server.replication.server with parameters of type UpdateMsg Modifier and Type Method Description voidReplicationServerDomain. put(UpdateMsg updateMsg, org.opends.server.replication.server.PeerServer sourceServer)Processes an update message received from a peer server, updating the server state and publishing the message to the changelog. -
Uses of UpdateMsg in org.opends.server.replication.server.changelog.api
Methods in org.opends.server.replication.server.changelog.api that return UpdateMsg Modifier and Type Method Description UpdateMsgUpdateRecord. getMessage()Returns the update message.UpdateMsgReplicationDomainDB. getNewestMessage(DomainReplicaId replica)Returns the newest message from the replica DB for the provided replica.Methods in org.opends.server.replication.server.changelog.api that return types with arguments of type UpdateMsg Modifier and Type Method Description DBCursor<UpdateMsg>ReplicationDomainDB. getCursorFrom(Dn baseDN, ServerState startState, DBCursor.CursorOptions options)Generates aDBCursoracross all the replicaDBs for the specified replication domain starting before, at or after the providedServerStatefor each replicaDB, depending on the provided matching and positioning strategies.DBCursor<UpdateMsg>ReplicationDomainDB. getCursorFrom(DomainReplicaId replica, CSN startCSN, DBCursor.CursorOptions options)Methods in org.opends.server.replication.server.changelog.api with parameters of type UpdateMsg Modifier and Type Method Description static UpdateRecordUpdateRecord. newUpdateRecord(Dn baseDn, UpdateMsg msg)Creates a new update record with the provided base DN and message.booleanReplicationDomainDB. publishUpdateMsg(Dn baseDN, UpdateMsg updateMsg)Publishes the provided change to the changelog DB for the specified replica id and replication domain. -
Uses of UpdateMsg in org.opends.server.replication.server.changelog.file
Methods in org.opends.server.replication.server.changelog.file that return UpdateMsg Modifier and Type Method Description UpdateMsgFileChangelogDB. getNewestMessage(DomainReplicaId replica)Methods in org.opends.server.replication.server.changelog.file that return types with arguments of type UpdateMsg Modifier and Type Method Description DBCursor<UpdateMsg>FileChangelogDB. getCursorFrom(Dn baseDN, ServerState startState, DBCursor.CursorOptions options)DBCursor<UpdateMsg>FileChangelogDB. getCursorFrom(DomainReplicaId replica, CSN startCsn, DBCursor.CursorOptions options)Methods in org.opends.server.replication.server.changelog.file with parameters of type UpdateMsg Modifier and Type Method Description voidChangeNumberIndexer. notifyUpdateMsg(Dn baseDn, UpdateMsg updateMsg)Ensures the medium consistency point is updated by UpdateMsg.booleanFileChangelogDB. publishUpdateMsg(Dn baseDN, UpdateMsg updateMsg) -
Uses of UpdateMsg in org.opends.server.replication.service
Methods in org.opends.server.replication.service with parameters of type UpdateMsg Modifier and Type Method Description abstract voidReplicationDomain. dispatchUpdateForReplay(UpdateMsg updateMsg)This method ensures thisUpdateMsgreceived from remote replication entities will be replayed, by dispatching it to the replay threads.protected voidReplicationDomain. processUpdateAfterReplay(UpdateMsg msg)This method must be called after each call toReplicationDomain.dispatchUpdateForReplay(UpdateMsg)when the processing of the update is completed.
-