public class RestoreTask extends SingleClientSenderTask
Task zur Wiederherstellung gesicherter Container.
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 |
---|
RestoreTask(ArchiveManager archiveMgr,
java.util.concurrent.BlockingQueue<java.lang.Object> inputData,
LongTermTaskStatePublisher longTermTaskStatePublisher)
Erzeugt einen neuen Task zur Wiederherstellung gesicherter Container.
|
Modifier and Type | Method and Description |
---|---|
void |
execute()
Diese Methode muss implementiert werden und definiert die Aktion, die dieser Task ausführt
|
static long |
getLOESSCHUTZ_VERL() |
static boolean |
isUnavailMediumIDsFile(java.lang.String name)
Prueft, ob der angegebene Dateiname der Name einer _unavailable_mediumids.dat-Datei ist.
|
static void |
setLOESSCHUTZ_VERL(long loesschutz_verl) |
protected void |
work(ResultData resultData)
Fuehrt die Wiederherstellung gesicherter Datenvontainer durch.
|
dataRequest, getObjectsFromDav, init, insertData, isRequestSupported, parseArchiveDataSpec, sendErrorResponse, sendErrorResponse, sendSuccessResponse, sendSuccessResponse, subscribeSender, unsubscribeSender
getQueue, step, submit, terminateTask
addTaskStepListener, cleanUp, getArchMgr, getName, getState, isAlive, isTerminated, join, removeTaskStepListener, setName, shouldTerminate, start, suspendTaskIfNecessary, taskStepDone
public RestoreTask(ArchiveManager archiveMgr, java.util.concurrent.BlockingQueue<java.lang.Object> inputData, LongTermTaskStatePublisher longTermTaskStatePublisher)
Erzeugt einen neuen Task zur Wiederherstellung gesicherter Container.
rodl
- Der Listener wird benachrichtigt beim Beenden der Task.archiveMgr
- Der Archiv-Manager.inputData
- Eingangswarteschlangepublic void execute()
Task
Diese Methode muss implementiert werden und definiert die Aktion, die dieser Task ausführt
execute
in class RepeatingTask
public static boolean isUnavailMediumIDsFile(java.lang.String name)
Prueft, ob der angegebene Dateiname der Name einer _unavailable_mediumids.dat-Datei ist.
name
- Name einer Dateiprotected void work(ResultData resultData)
Fuehrt die Wiederherstellung gesicherter Datenvontainer durch.
work
in class QueueTask<ResultData>
resultData
- Zu verarbeitender Datensatz aus der Eingangswarteschlange.public static long getLOESSCHUTZ_VERL()
public static void setLOESSCHUTZ_VERL(long loesschutz_verl)