org.opends.server.replication.server
Class ServerWriter

java.lang.Object
  extended by java.lang.Thread
      extended by org.opends.server.api.DirectoryThread
          extended by org.opends.server.replication.server.ServerWriter
All Implemented Interfaces:
java.lang.Runnable

public class ServerWriter
extends DirectoryThread

This class defines a server writer, which is used to send changes to a directory 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
ServerWriter(ProtocolSession session, short serverId, ServerHandler handler, ReplicationServerDomain replicationServerDomain)
          Create a ServerWriter.
 
Method Summary
 void run()
          Run method for the ServerWriter.
 
Methods inherited from class org.opends.server.api.DirectoryThread
getAssociatedTask, getCreationStackTrace, getDebugProperties, getParentThread, setAssociatedTask
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ServerWriter

public ServerWriter(ProtocolSession session,
                    short serverId,
                    ServerHandler handler,
                    ReplicationServerDomain replicationServerDomain)
Create a ServerWriter. Then ServerWriter then waits on the ServerHandler for new updates and forward them to the server

Parameters:
session - the ProtocolSession that will be used to send updates.
serverId - the Identifier of the server.
handler - handler for which the ServerWriter is created.
replicationServerDomain - The ReplicationServerDomain of this ServerWriter.
Method Detail

run

public void run()
Run method for the ServerWriter. Loops waiting for changes from the ReplicationServerDomain and forward them to the other servers

Specified by:
run in interface java.lang.Runnable
Overrides:
run in class java.lang.Thread