public class ChangeNumberIndexer extends DirectoryThread
Only updates older than the medium consistency point are inserted in the CNIndexDB. As a consequence this class is also responsible for maintaining the medium consistency point.
Thread.State, Thread.UncaughtExceptionHandler
DIRECTORY_THREAD_GROUP
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ChangeNumberIndexer(ChangelogDB changelogDB,
ChangelogStateProvider changelogStateProvider)
Builds a ChangeNumberIndexer object.
|
Modifier and Type | Method and Description |
---|---|
void |
initiateShutdown()
Instructs the current thread to initiate the shutdown process.
|
void |
publishHeartbeat(Dn baseDn,
CSN heartbeatCsn)
Ensures the medium consistency point is updated by heartbeats.
|
void |
publishUpdateMsg(Dn baseDn,
UpdateMsg updateMsg)
Ensures the medium consistency point is updated by UpdateMsg.
|
void |
run() |
getAssociatedTask, getCreationStackTrace, getDebugProperties, getParentThread, isShutdownInitiated, isStarted, isStarting, setAssociatedTask, setStarted
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogStateProvider changelogStateProvider)
changelogDB
- the changelogDBchangelogStateProvider
- the replication environment information for access to changelog statepublic void publishHeartbeat(Dn baseDn, CSN heartbeatCsn)
baseDn
- the baseDN of the domain for which the heartbeat is publishedheartbeatCsn
- the CSN coming from the heartbeatpublic void publishUpdateMsg(Dn baseDn, UpdateMsg updateMsg)
baseDn
- the baseDN of the domain for which the heartbeat is publishedupdateMsg
- the updateMsg that will update the medium consistency pointpublic void initiateShutdown()
DirectoryThread
Thread.run()
method.initiateShutdown
in class DirectoryThread
Copyright 2010-2022 ForgeRock AS.