de.bsvrz.ars.ars.mgmt.tasks
Class ArchiveSettingsTask

java.lang.Object
  extended by java.lang.Thread
      extended by de.bsvrz.ars.ars.mgmt.tasks.Task
          extended by de.bsvrz.ars.ars.mgmt.tasks.SingleTask
              extended by de.bsvrz.ars.ars.mgmt.tasks.ArchiveSettingsTask
All Implemented Interfaces:
SuspendableTask, Runnable

public class ArchiveSettingsTask
extends SingleTask

Task zur Umsetzung der Archiveinstellungen. Dies betrifft die Attributgruppen "atg.archivEinstellung" und "atg.archivContainer". Das Ende eines Uebernahmezyklus eines jeden dieser Parameter kann man mit createSettingLstnr(int) abwarten.

Author:
beck et al. projects GmbH, Alexander Schmidt

Nested Class Summary
 class ArchiveSettingsTask.ArSSettingListener
          Spezielle Klasse, mit der man auf das Ende der Übernahme der nächsten Archiveinstellungen warten kann.
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
static int ARCHIVCONTAINER
           
static int ARCHIVEINST
           
static int MIN_CONTAINER_MAXDS
          Minimumwerte für ContainerSettings.stdCloseConditions: 1 Datensatz pro Container
static int MIN_CONTAINER_MAXSIZE
          Minimumwerte für ContainerSettings.stdCloseConditions: 4096 (entspricht einer Blockgroesse)
static int MIN_CONTAINER_MAXTIME
          Minimumwerte für ContainerSettings.stdCloseConditions: 1 Minute
private static String SETTINGS_ASPECT
          Unter diesem Aspekt werden die Einstellungen abonniert
private  List[] settingsListener
           
private static long[] SUBSCR_IDS
           
static String[][] SUBSCR_PIDS
          Diese Datenidentifikationen werden angemeldet
 
Fields inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task
archMgr, didTree, INDEX_MEMORY_SIZE, isTerminated, logger, persMgr, ringOfDeathListener, taskStepListeners
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
ArchiveSettingsTask(ArchiveManager archMgr, RingOfDeathListener rodl, RingBuffer<ResultData> inputData)
           
 
Method Summary
 ArchiveSettingsTask.ArSSettingListener createSettingLstnr(int subscription)
           
private  void notifyListener(int subscr)
           
static void subscribeObjects(ArchiveManager archMgr, InQueuesMgr.DataReceiver receiver)
          Fuehrt alle notwendigen Anmeldungen durch.
protected  void work(ResultData resultData)
          Diese Methode ist zu ueberschreiben, um die konkrete Aufgabe der Task zu implementieren.
 
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.SingleTask
run
 
Methods inherited from class de.bsvrz.ars.ars.mgmt.tasks.Task
addTaskStepListener, getArchMgr, isTaskTerminated, removeTaskStepListener, suspendTaskIfNecessary, terminateTask
 
Methods inherited from class java.lang.Thread
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
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

SETTINGS_ASPECT

private static String SETTINGS_ASPECT
Unter diesem Aspekt werden die Einstellungen abonniert


MIN_CONTAINER_MAXDS

public static final int MIN_CONTAINER_MAXDS
Minimumwerte für ContainerSettings.stdCloseConditions: 1 Datensatz pro Container

See Also:
Constant Field Values

MIN_CONTAINER_MAXSIZE

public static final int MIN_CONTAINER_MAXSIZE
Minimumwerte für ContainerSettings.stdCloseConditions: 4096 (entspricht einer Blockgroesse)

See Also:
Constant Field Values

MIN_CONTAINER_MAXTIME

public static final int MIN_CONTAINER_MAXTIME
Minimumwerte für ContainerSettings.stdCloseConditions: 1 Minute

See Also:
Constant Field Values

ARCHIVEINST

public static final int ARCHIVEINST
See Also:
Constant Field Values

ARCHIVCONTAINER

public static final int ARCHIVCONTAINER
See Also:
Constant Field Values

SUBSCR_PIDS

public static String[][] SUBSCR_PIDS
Diese Datenidentifikationen werden angemeldet


SUBSCR_IDS

private static long[] SUBSCR_IDS

settingsListener

private List[] settingsListener
Constructor Detail

ArchiveSettingsTask

public ArchiveSettingsTask(ArchiveManager archMgr,
                           RingOfDeathListener rodl,
                           RingBuffer<ResultData> inputData)
                    throws ConfigurationException
Throws:
ConfigurationException
Method Detail

subscribeObjects

public static void subscribeObjects(ArchiveManager archMgr,
                                    InQueuesMgr.DataReceiver receiver)
Fuehrt alle notwendigen Anmeldungen durch.

Parameters:
davCon - Verbindung zum Datenverteiler
receiver - Empfaengerobjekt

createSettingLstnr

public ArchiveSettingsTask.ArSSettingListener createSettingLstnr(int subscription)

work

protected void work(ResultData resultData)
Description copied from class: SingleTask
Diese Methode ist zu ueberschreiben, um die konkrete Aufgabe der Task zu implementieren. In der Methode soll keine weitere Warteschlangen-Synchronisation stattfinden.

Specified by:
work in class SingleTask
Parameters:
resultData - Zu verarbeitender Datensatz aus der Eingangswarteschlange

notifyListener

private void notifyListener(int subscr)