public class QueryInfoTask extends SingleClientSenderTask
Thread.State, Thread.UncaughtExceptionHandler
atgQuery, ddResponse, deserializer, queryAppObj, queryIdx, SENDCONTROL_TIMEOUT, serializerVersion, syncObj
archMgr, didTree, INDEX_MEMORY_SIZE, isTerminated, logger, persMgr, ringOfDeathListener, taskStepListeners
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION
Constructor and Description |
---|
QueryInfoTask(ArchiveManager archMgr,
RingOfDeathListener inQueuesMgr,
RingBuffer<ResultData> nonArchQueue) |
Modifier and Type | Method and Description |
---|---|
protected void |
insertData(Serializer serializer) |
protected void |
work(ResultData resultData)
Diese Methode ist zu ueberschreiben, um die konkrete Aufgabe der Task zu implementieren.
|
dataRequest, getObjectsFromDAV, init, isRequestSupported, parseArchiveDataSpec, sendErrorResponse, sendErrorResponse, sendSuccessResponse, sendSuccessResponse, subscribeSender, unsubscribeSender
run
addTaskStepListener, getArchMgr, isTaskTerminated, removeTaskStepListener, suspendTaskIfNecessary, terminateTask
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 QueryInfoTask(ArchiveManager archMgr, RingOfDeathListener inQueuesMgr, RingBuffer<ResultData> nonArchQueue)
protected void work(ResultData resultData)
SingleTask
work
in class SingleTask
resultData
- Zu verarbeitender Datensatz aus der Eingangswarteschlangeprotected void insertData(Serializer serializer) throws IOException
insertData
in class SingleClientSenderTask
IOException