java.lang.Runnable
, RequestProcessor
public class CommitProcessor extends ZooKeeperCriticalThread implements RequestProcessor
RequestProcessor.RequestProcessorException
Constructor | Description |
---|---|
CommitProcessor(RequestProcessor nextProcessor,
java.lang.String id,
boolean matchSyncs,
ZooKeeperServerListener listener) |
Modifier and Type | Method | Description |
---|---|---|
void |
commit(Request request) |
|
void |
processRequest(Request request) |
|
void |
run() |
|
void |
shutdown() |
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
handleException
public CommitProcessor(RequestProcessor nextProcessor, java.lang.String id, boolean matchSyncs, ZooKeeperServerListener listener)
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void commit(Request request)
public void processRequest(Request request)
processRequest
in interface RequestProcessor
public void shutdown()
shutdown
in interface RequestProcessor
Copyright © 2018 The Apache Software Foundation