public class ObserverRequestProcessor extends ZooKeeperCriticalThread implements RequestProcessor
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
RequestProcessor.RequestProcessorException
Constructor and Description |
---|
ObserverRequestProcessor(ObserverZooKeeperServer zks,
RequestProcessor nextProcessor)
Constructor - takes an ObserverZooKeeperServer to associate with
and the next processor to pass requests to after we're finished.
|
Modifier and Type | Method and Description |
---|---|
void |
processRequest(Request request)
Simply queue the request, which will be processed in FIFO order.
|
void |
run() |
void |
shutdown()
Shutdown the processor.
|
handleException
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 ObserverRequestProcessor(ObserverZooKeeperServer zks, RequestProcessor nextProcessor)
zks
- nextProcessor
- public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void processRequest(Request request)
processRequest
in interface RequestProcessor
public void shutdown()
shutdown
in interface RequestProcessor
Copyright © 2017 The Apache Software Foundation