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 void
LDAPReplicationDomain. 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 class
AddMsg
This class is used to exchange Add operation between LDAP servers and replication servers.class
DeleteMsg
Object used when sending delete information to replication servers.class
LDAPUpdateMsg
Abstract class that must be extended to define a message used for sending Updates between servers.class
ModifyCommonMsg
This class holds every common code for the modify messages (mod, moddn).class
ModifyDNMsg
Message used to send Modify DN information.class
ModifyMsg
Message used to send Modify information.class
ReplicaOfflineMsg
Class 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 aPublisher
that: 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 int
UpdateMsg. 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 aPublisher
that: 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 void
ReplicationServerDomain. 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 UpdateMsg
UpdateRecord. getMessage()
Returns the update message.UpdateMsg
ReplicationDomainDB. 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 aDBCursor
across all the replicaDBs for the specified replication domain starting before, at or after the providedServerState
for 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 UpdateRecord
UpdateRecord. newUpdateRecord(Dn baseDn, UpdateMsg msg)
Creates a new update record with the provided base DN and message.boolean
ReplicationDomainDB. 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 UpdateMsg
FileChangelogDB. 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 void
ChangeNumberIndexer. notifyUpdateMsg(Dn baseDn, UpdateMsg updateMsg)
Ensures the medium consistency point is updated by UpdateMsg.boolean
FileChangelogDB. 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 void
ReplicationDomain. dispatchUpdateForReplay(UpdateMsg updateMsg)
This method ensures thisUpdateMsg
received from remote replication entities will be replayed, by dispatching it to the replay threads.protected void
ReplicationDomain. processUpdateAfterReplay(UpdateMsg msg, long etimeNanos)
This method must be called after each call toReplicationDomain.dispatchUpdateForReplay(UpdateMsg)
when the processing of the update is completed.
-