public class DeleteSimVarTask extends SingleClientSenderTask
SimulationAutomaton
eingehende Löschaufträge zu verarbeiten. Die Daten werden sowohl von dem Filesystem entfernt und die
betroffenen DataIdentNodes werden aus dem DIN-Tree genommen.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 |
---|
DeleteSimVarTask(ArchiveManager archiveMgr,
RingOfDeathListener rodl,
RingBuffer<ResultData> inputData) |
Modifier and Type | Method and Description |
---|---|
private void |
deleteSimVarClient(ResultData resultData)
Führt Löschauftrag durch, der von einem Client gestellt wurde.
|
private void |
deleteSimVarSimulation(SimulationResultData srd)
Führt Löschauftrag durch, der von einer Simulation gestellt wurde.
|
private void |
executeDelete(short simVarToDelete)
Löscht die Daten einer Simulationsvariante.
|
protected void |
work(ResultData resultData)
Diese Methode ist zu ueberschreiben, um die konkrete Aufgabe der Task zu implementieren.
|
dataRequest, getObjectsFromDAV, init, insertData, 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 DeleteSimVarTask(ArchiveManager archiveMgr, RingOfDeathListener rodl, RingBuffer<ResultData> inputData) throws ConfigurationException
protected void work(ResultData resultData)
SingleTask
work
in class SingleTask
resultData
- Zu verarbeitender Datensatz aus der EingangswarteschlangeSingleTask.work(ResultData)
private void deleteSimVarSimulation(SimulationResultData srd) throws IOException, PersistenceException
srd
- Auftragsparameter.PersistenceException
IOException
private void deleteSimVarClient(ResultData resultData) throws IOException, PersistenceException
resultData
- AuftragsdatenPersistenceException
IOException
private void executeDelete(short simVarToDelete) throws IOException, PersistenceException
simVarToDelete
- Simulationsvariante.IOException
- Fehler beim Deserialisieren der Daten aus data
.PersistenceException
- Fehler beim Löschen der Daten.