Package de.bsvrz.pua.prot.processing
Class ProtocolReader
- java.lang.Object
-
- de.bsvrz.pua.prot.processing.BasicFlowControl
-
- de.bsvrz.pua.prot.processing.ProtocolReader
-
- All Implemented Interfaces:
ProcessingInterface
public class ProtocolReader extends BasicFlowControl implements ProcessingInterface
Lies ein gespeichertes Protokoll ein und versendet es an einen Empfänger
-
-
Field Summary
-
Fields inherited from class de.bsvrz.pua.prot.processing.BasicFlowControl
_maxDelay, _pause
-
-
Constructor Summary
Constructors Constructor Description ProtocolReader(PuaSender sender, de.bsvrz.sys.funclib.losb.datk.SerializerUtil serializer, long protocolId, long maxDelay, int timeout, DataManagerInterface dataManager, long jobId, 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
-
ProtocolReader
public ProtocolReader(PuaSender sender, de.bsvrz.sys.funclib.losb.datk.SerializerUtil serializer, long protocolId, long maxDelay, int timeout, DataManagerInterface dataManager, long jobId, long initialFlowControl)
Erzeugt ein Objekt zur Datenaufbereitung.- Parameters:
sender
- Objekt zum Versand der Daten.serializer
- SerializerprotocolId
- Id des zu erstellenden Protokolls.maxDelay
- Maximale Zeitdauer in ms für die die Protokollerstellung angehalten werden kann.timeout
- TimeoutjobId
- JobIdinitialFlowControl
- InitialFlowControldataManager
- DataManager
-
-
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.- See Also:
ProcessingInterface.process(boolean)
-
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()
-
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
-
getClient
protected java.lang.Object getClient()
- Specified by:
getClient
in classBasicFlowControl
-
-