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, resumeProcessing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
flowControl, pauseProcessing, resumeProcessing
private 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)
ProcessingInterface
process
in interface ProcessingInterface
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.ProcessingInterface.process(boolean)
public void abort()
abort
in interface ProcessingInterface
ProcessingInterface.abort()
public byte getStatus()
ProcessingInterface
getStatus
in interface ProcessingInterface
ProcessingInterface.getStatus()
public long getProtocolId()
ProcessingInterface
getProtocolId
in interface ProcessingInterface
ProcessingInterface.getProtocolId()
public long getJobId()
ProcessingInterface
getJobId
in interface ProcessingInterface
getJobId
in class BasicFlowControl
public JobState getJobState()
ProcessingInterface
getJobState
in interface ProcessingInterface
public void stopProtocolTransmission()
ProcessingInterface
stopProtocolTransmission
in interface ProcessingInterface
protected java.lang.Object getClient()
getClient
in class BasicFlowControl