Uses of Class
org.opends.server.replication.protocol.UpdateMsg

Packages that use UpdateMsg

Package	Description
org.opends.server.backends	Contains various Directory Server backend implementations.
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.backends

Methods in org.opends.server.backends with parameters of type UpdateMsg

Modifier and Type	Method	Description
void	ChangelogBackend.notifyChangeNumberEntryAdded(ChangeNumberIndexRecord record, UpdateMsg updateMsg)	Notifies persistent searches of this backend that a new change number entry was added to it.

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 via ReplicationDomain.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
final class	AddMsg	This class is used to exchange Add operation between LDAP servers and replication servers.
final 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).
final class	ModifyDNMsg	Message used to send Modify DN information.
final class	ModifyMsg	Message used to send Modify information.
final 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 a Publisher 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 a Publisher 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	ReplicationDomainDB.getNewestMessage(DomainReplicaId replica)	Returns the newest message from the replica DB for the provided replica.
UpdateMsg	UpdateRecord.updateMsg()	Returns the value of the updateMsg record component.

Methods in org.opends.server.replication.server.changelog.api that return types with arguments of type UpdateMsg

Modifier and Type	Method	Description
Map<StreamId,DBCursor<Record<CSN,UpdateMsg>>>	ReplicationDomainDB.getChangelogCursors(Dn baseDN)	Generates DBCursor for all streams of a given domain.
DBCursor<UpdateMsg>	ReplicationDomainDB.getCursorFrom(Dn baseDN, ServerState startState, DBCursor.CursorOptions options)	Generates a DBCursor across all the replicaDBs for the specified replication domain starting before, at or after the provided ServerState for each replicaDB, depending on the provided matching and positioning strategies.
DBCursor<UpdateMsg>	ReplicationDomainDB.getCursorFrom(DomainReplicaId replica, CSN startCSN, DBCursor.CursorOptions options)	Generates a DBCursor for one replicaDB for the specified replication domain and replica id starting before, at or after the provided CSN, depending on the provided matching and positioning strategies.
DBCursor<Record<CSN,UpdateMsg>>	ReplicationDomainDB.getStreamIdCursor(DomainReplicaId domainReplicaId, StreamId streamId)	Generates a DBCursor for a given stream of a replica.

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.

Constructors in org.opends.server.replication.server.changelog.api with parameters of type UpdateMsg

Modifier	Constructor	Description
	UpdateRecord(Dn baseDn, UpdateMsg updateMsg)	Creates an instance of a UpdateRecord record class.

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
Map<StreamId,DBCursor<Record<CSN,UpdateMsg>>>	FileChangelogDB.getChangelogCursors(Dn baseDN)
DBCursor<UpdateMsg>	FileChangelogDB.getCursorFrom(Dn baseDN, ServerState startState, DBCursor.CursorOptions options)
DBCursor<UpdateMsg>	FileChangelogDB.getCursorFrom(DomainReplicaId replica, CSN startCsn, DBCursor.CursorOptions options)
org.opends.server.replication.server.changelog.file.Log<CSN,StreamId,UpdateMsg>	ReplicationEnvironment.getOrCreateReplicaDB(DomainReplicaId domainReplicaId, GenerationId generationId)	Finds or creates the log used to store changes from the replication server with the given replica id and the given baseDN.
DBCursor<Record<CSN,UpdateMsg>>	FileChangelogDB.getStreamIdCursor(DomainReplicaId replicaId, StreamId streamId)	Returns a cursor for a given replicaId and streamId.

Methods in org.opends.server.replication.server.changelog.file with parameters of type UpdateMsg

Modifier and Type	Method	Description
@org.opends.server.replication.common.ReplicationImplementation(appliesTo="LeaderBasedReplication, Multimaster", rationale="remove temporary workaround to avoid NPE with LBR") 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 this UpdateMsg received from remote replication entities will be replayed, by dispatching it to the replay threads.
protected final void	ReplicationDomain.processUpdateAfterReplay(UpdateMsg msg, long etimeNanos)	This method must be called after each call to ReplicationDomain.dispatchUpdateForReplay(UpdateMsg) when the processing of the update is completed.