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 void
abort()
Bricht die Datenaufbereitung ab.protected java.lang.Object
getClient()
long
getJobId()
Gibt die Auftrags-Id zurückJobState
getJobState()
Gibt den Status des Auftrags zurücklong
getProtocolId()
Zum Abfragen der Protokoll-Id.byte
getStatus()
Anfrage nach dem Status der Datenaufbereitungvoid
process(boolean abortProcessing)
Startet die Datenaufbereitung.void
stopProtocolTransmission()
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 dempi
generiert 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:ProcessingInterface
Startet die Datenaufbereitung.- Specified by:
process
in 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:
abort
in interfaceProcessingInterface
- See Also:
ProcessingInterface.abort()
-
getStatus
public byte getStatus()
Description copied from interface:ProcessingInterface
Anfrage nach dem Status der Datenaufbereitung- Specified by:
getStatus
in interfaceProcessingInterface
- Returns:
- Statusinformation
- See Also:
ProcessingInterface.getStatus()
-
getProtocolId
public long getProtocolId()
Description copied from interface:ProcessingInterface
Zum Abfragen der Protokoll-Id.- Specified by:
getProtocolId
in interfaceProcessingInterface
- Returns:
- Liefert die Protokoll-Id des Protokolls.
- See Also:
ProcessingInterface.getProtocolId()
-
getClient
protected java.lang.Object getClient()
- Specified by:
getClient
in classBasicFlowControl
-
getJobId
public long getJobId()
Description copied from interface:ProcessingInterface
Gibt die Auftrags-Id zurück- Specified by:
getJobId
in interfaceProcessingInterface
- Specified by:
getJobId
in classBasicFlowControl
- Returns:
- Id des Auftrags
-
getJobState
public JobState getJobState()
Description copied from interface:ProcessingInterface
Gibt den Status des Auftrags zurück- Specified by:
getJobState
in interfaceProcessingInterface
- Returns:
- Status
-
stopProtocolTransmission
public void stopProtocolTransmission()
Description copied from interface:ProcessingInterface
Bricht 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:
stopProtocolTransmission
in interfaceProcessingInterface
-
-