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 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
-
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: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.- See Also:
ProcessingInterface.process(boolean)
-
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()
-
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
-
getClient
protected java.lang.Object getClient()
- Specified by:
getClientin classBasicFlowControl
-
-