Package de.bsvrz.pua.prot.processing
Class Processing
- java.lang.Object
-
- de.bsvrz.pua.prot.processing.BasicFlowControl
-
- de.bsvrz.pua.prot.processing.Processing
-
- All Implemented Interfaces:
ProcessingInterface
public class Processing extends BasicFlowControl implements ProcessingInterface
Führt die Datenaufbereitung durch.
-
-
Field Summary
-
Fields inherited from class de.bsvrz.pua.prot.processing.BasicFlowControl
_maxDelay, _pause
-
-
Constructor Summary
Constructors Constructor Description Processing(PuaSender sender, DataManagerInterface dataManager, de.bsvrz.sys.funclib.losb.datk.SerializerUtil serializer, long protocolId, ProcessingParameter pp, ProcessingInformation pi, de.bsvrz.sys.funclib.losb.datk.AtlMeta atlMeta, de.bsvrz.dav.daf.main.config.ConfigurationObject configAuth, long maxDelay, int timeout, long initialFlowControl)Erzeugt ein Objekt zur Datenaufbereitung.
-
Method Summary
Modifier and Type Method Description voidabort()Bricht die Datenaufbereitung ab.protected java.lang.ObjectgetClient()longgetJobId()Gibt die Auftrags-Id zurückJobStategetJobState()Gibt den Status des Auftrags zurücklonggetProtocolId()Zum Abfragen der Protokoll-Id.bytegetStatus()Anfrage nach dem Status der Datenaufbereitungvoidprocess(boolean abortProcessing)Startet die Datenaufbereitung.voidstopProtocolTransmission()Bricht die Übertragung des Protokolls ab.-
Methods inherited from class de.bsvrz.pua.prot.processing.BasicFlowControl
datasetSend, flowControl, flowControl, getTimeout, pauseProcessing, resumeProcessing
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface de.bsvrz.pua.prot.processing.ProcessingInterface
flowControl, pauseProcessing, resumeProcessing
-
-
-
-
Constructor Detail
-
Processing
public Processing(PuaSender sender, DataManagerInterface dataManager, de.bsvrz.sys.funclib.losb.datk.SerializerUtil serializer, long protocolId, ProcessingParameter pp, ProcessingInformation pi, de.bsvrz.sys.funclib.losb.datk.AtlMeta atlMeta, de.bsvrz.dav.daf.main.config.ConfigurationObject configAuth, long maxDelay, int timeout, long initialFlowControl)
Erzeugt ein Objekt zur Datenaufbereitung.- Parameters:
sender- Objekt zum Versand der Daten.dataManager- Verbindung zum Daten Manager. Bei Bedarf speichert Daten Manager das Protokoll.serializer- Objekt zum Zippen und Serialisieren der Ergebnisdaten.protocolId- Id des zu erstellenden Protokolls.pp- Auftragsparameter.pi- Zur Protokollerstellung benötigte Informationen.atlMeta- Metainformationen zum Skript aus dempigeneriert wurde. Werden für den Administrationsdatensatz benötigt.configAuth- Konfigurationsverantwortlicher für Anfragen an das Archivsystem.maxDelay- Maximale Zeitdauer in ms für die die Protokollerstellung angehalten werden kann.timeout- TimeoutinitialFlowControl- InitialFlowControl
-
-
Method Detail
-
process
public void process(boolean abortProcessing)
Description copied from interface:ProcessingInterfaceStartet die Datenaufbereitung.- Specified by:
processin interfaceProcessingInterface- Parameters:
abortProcessing- Zeigt an ob die Datenaufbereitung abgebrochen werden soll.In diesem Fall wird eine negative Quittung an den Auftraggeber gesandt. Administrations- und Aggregations- Datensatz werden immer an den Auftraggeber gesendet.
-
abort
public void abort()
Bricht die Datenaufbereitung ab.- Specified by:
abortin interfaceProcessingInterface- See Also:
ProcessingInterface.abort()
-
getStatus
public byte getStatus()
Description copied from interface:ProcessingInterfaceAnfrage nach dem Status der Datenaufbereitung- Specified by:
getStatusin interfaceProcessingInterface- Returns:
- Statusinformation
- See Also:
ProcessingInterface.getStatus()
-
getProtocolId
public long getProtocolId()
Description copied from interface:ProcessingInterfaceZum Abfragen der Protokoll-Id.- Specified by:
getProtocolIdin interfaceProcessingInterface- Returns:
- Liefert die Protokoll-Id des Protokolls.
- See Also:
ProcessingInterface.getProtocolId()
-
getClient
protected java.lang.Object getClient()
- Specified by:
getClientin classBasicFlowControl
-
getJobId
public long getJobId()
Description copied from interface:ProcessingInterfaceGibt die Auftrags-Id zurück- Specified by:
getJobIdin interfaceProcessingInterface- Specified by:
getJobIdin classBasicFlowControl- Returns:
- Id des Auftrags
-
getJobState
public JobState getJobState()
Description copied from interface:ProcessingInterfaceGibt den Status des Auftrags zurück- Specified by:
getJobStatein interfaceProcessingInterface- Returns:
- Status
-
stopProtocolTransmission
public void stopProtocolTransmission()
Description copied from interface:ProcessingInterfaceBricht die Übertragung des Protokolls ab. Im Gegensatz zu abort wird das Protokoll trotzdem noch zuende berechnet und gespeichert (wenn es sich um einen entsprechenden Auftrag handelt)- Specified by:
stopProtocolTransmissionin interfaceProcessingInterface
-
-