public class Processing extends BasicFlowControl implements ProcessingInterface
_maxDelay, _pause
Constructor and Description |
---|
Processing(PuaSender sender,
DataManagerInterface dataManager,
SerializerUtil serializer,
long protocolId,
ProcessingParameter pp,
ProcessingInformation pi,
AtlMeta atlMeta,
ConfigurationObject configAuth,
long maxDelay,
int timeout,
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
public Processing(PuaSender sender, DataManagerInterface dataManager, SerializerUtil serializer, long protocolId, ProcessingParameter pp, ProcessingInformation pi, AtlMeta atlMeta, ConfigurationObject configAuth, long maxDelay, int timeout, long initialFlowControl)
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 dem pi
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
- 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()
protected java.lang.Object getClient()
getClient
in class BasicFlowControl
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