org.opends.server.replication.plugin
Class ListenerThread

java.lang.Object
  java.lang.Thread
      org.opends.server.api.DirectoryThread
          org.opends.server.replication.plugin.ListenerThread

All Implemented Interfaces:

java.lang.Runnable

public class ListenerThread
extends DirectoryThread

Thread that is used to get messages from the Replication servers and replay them in the current server.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ListenerThread(ReplicationDomain repDomain, java.util.concurrent.LinkedBlockingQueue<UpdateToReplay> updateToReplayQueue)
Constructor for the ListenerThread.

Method Summary

void	run() Run method for this class.
void	shutdown() Shutdown this listener thread.
void	waitForShutdown() Wait for the completion of this thread.

Methods inherited from class org.opends.server.api.DirectoryThread

getAssociatedTask, getCreationStackTrace, getDebugProperties, getParentThread, setAssociatedTask

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ListenerThread

public ListenerThread(ReplicationDomain repDomain,
                      java.util.concurrent.LinkedBlockingQueue<UpdateToReplay> updateToReplayQueue)

Constructor for the ListenerThread.

Parameters:

repDomain - the replication domain that created this thread

updateToReplayQueue - The update messages queue we must store messages in

Method Detail

shutdown

public void shutdown()

Shutdown this listener thread.

run

public void run()

Run method for this class.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

waitForShutdown

public void waitForShutdown()

Wait for the completion of this thread.