public class QueryInfoTask extends SingleClientSenderTask
Klasse, die einfache Anfragen bzgl. der maximalen Anzahl ausführbarer Archivanfragen entgegennimmt. Kann ggf. um weitere Abfragen erweitert werden.
atgQuery, ddResponse, deserializer, queryAppObj, queryIdx, SENDCONTROL_TIMEOUT, serializerVersion, syncObj
TERMINATE_TASK
_debug, _shouldTerminate, archMgr, didTree, INDEX_MEMORY_SIZE, persMgr
START_SENDING, STOP_SENDING, STOP_SENDING_NO_RIGHTS, STOP_SENDING_NOT_A_VALID_SUBSCRIPTION
Constructor and Description |
---|
QueryInfoTask(ArchiveManager archMgr,
java.util.concurrent.BlockingQueue<java.lang.Object> nonArchQueue) |
Modifier and Type | Method and Description |
---|---|
protected void |
insertData(Serializer serializer) |
protected void |
work(ResultData resultData) |
dataRequest, getObjectsFromDav, init, isRequestSupported, parseArchiveDataSpec, sendErrorResponse, sendErrorResponse, sendSuccessResponse, sendSuccessResponse, subscribeSender, unsubscribeSender
getQueue, step, submit, terminateTask
execute
addTaskStepListener, cleanUp, getArchMgr, getName, getState, isAlive, isTerminated, join, removeTaskStepListener, setName, shouldTerminate, start, suspendTaskIfNecessary, taskStepDone
public QueryInfoTask(ArchiveManager archMgr, java.util.concurrent.BlockingQueue<java.lang.Object> nonArchQueue)
protected void work(ResultData resultData)
work
in class QueueTask<ResultData>
protected void insertData(Serializer serializer) throws java.io.IOException
insertData
in class SingleClientSenderTask
java.io.IOException