public class ObserverRequestProcessor extends ZooKeeperCriticalThread implements RequestProcessor
Thread.State, Thread.UncaughtExceptionHandler
RequestProcessor.RequestProcessorException
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
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 processRequest(Request request)
processRequest
in interface RequestProcessor
public void shutdown()
shutdown
in interface RequestProcessor
Copyright © 2008–2020 The Apache Software Foundation. All rights reserved.