public class ProtocolReader extends BasicFlowControl implements ProcessingInterface
| Modifier and Type | Field and Description |
|---|---|
private boolean |
_abort
Zeigt ob der Vorgang abgebrochen wurde.
|
private DataManagerInterface |
_dataManager |
private static Debug |
_debug |
private long |
_jobId
Auftrags-ID
|
private JobState |
_jobState |
private long |
_protocolId
Protokoll-Id
|
private PuaSender |
_sender
Objekt zum Versand der Daten
|
private SerializerUtil |
_serializer |
private byte |
_status
Status der Datenaufbereitung
|
private java.lang.Thread |
_thread
Der Thread der den Vorgang ausführt.
|
_maxDelay, _pause| Constructor and Description |
|---|
ProtocolReader(PuaSender sender,
SerializerUtil serializer,
long protocolId,
long maxDelay,
int timeout,
DataManagerInterface dataManager,
long jobId,
long initialFlowControl)
Erzeugt ein Objekt zur Datenaufbereitung.
|
| Modifier and Type | Method and Description |
|---|---|
void |
abort()
Bricht die Datenaufbereitung ab.
|
protected java.lang.Object |
getClient() |
long |
getJobId()
Gibt die Auftrags-Id zurück
|
JobState |
getJobState()
Gibt den Status des Auftrags zurück
|
long |
getProtocolId()
Zum Abfragen der Protokoll-Id.
|
byte |
getStatus()
Anfrage nach dem Status der Datenaufbereitung
|
void |
process(boolean abortProcessing)
Startet die Datenaufbereitung.
|
void |
stopProtocolTransmission()
Bricht die Übertragung des Protokolls ab.
|
datasetSend, flowControl, flowControl, getTimeout, pauseProcessing, resumeProcessingclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitflowControl, pauseProcessing, resumeProcessingprivate static final Debug _debug
private final long _protocolId
private final PuaSender _sender
private volatile boolean _abort
private byte _status
private final SerializerUtil _serializer
private final java.lang.Thread _thread
private final DataManagerInterface _dataManager
private final long _jobId
private volatile JobState _jobState
public ProtocolReader(PuaSender sender, SerializerUtil serializer, long protocolId, long maxDelay, int timeout, DataManagerInterface dataManager, long jobId, long initialFlowControl)
sender - Objekt zum Versand der Daten.serializer - protocolId - Id des zu erstellenden Protokolls.maxDelay - Maximale Zeitdauer in ms für die die Protokollerstellung angehalten werden kann.timeout - jobId - initialFlowControl - public void process(boolean abortProcessing)
ProcessingInterfaceprocess in interface ProcessingInterfaceabortProcessing - 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.ProcessingInterface.process(boolean)public void abort()
abort in interface ProcessingInterfaceProcessingInterface.abort()public byte getStatus()
ProcessingInterfacegetStatus in interface ProcessingInterfaceProcessingInterface.getStatus()public long getProtocolId()
ProcessingInterfacegetProtocolId in interface ProcessingInterfaceProcessingInterface.getProtocolId()public long getJobId()
ProcessingInterfacegetJobId in interface ProcessingInterfacegetJobId in class BasicFlowControlpublic JobState getJobState()
ProcessingInterfacegetJobState in interface ProcessingInterfacepublic void stopProtocolTransmission()
ProcessingInterfacestopProtocolTransmission in interface ProcessingInterfaceprotected java.lang.Object getClient()
getClient in class BasicFlowControl