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, resumeProcessingclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitflowControl, pauseProcessing, resumeProcessingpublic 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)
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()protected java.lang.Object getClient()
getClient in class BasicFlowControlpublic long getJobId()
ProcessingInterfacegetJobId in interface ProcessingInterfacegetJobId in class BasicFlowControlpublic JobState getJobState()
ProcessingInterfacegetJobState in interface ProcessingInterfacepublic void stopProtocolTransmission()
ProcessingInterfacestopProtocolTransmission in interface ProcessingInterface