public class ProtocolAnswerReceiver extends AnswerReceiver
| Modifier and Type | Field and Description |
|---|---|
private boolean |
_createProtocolRequest
true wenn der Receiver verwendet werden soll. |
private static Debug |
_debug
Debug Ausgabe
|
private boolean |
_receivedFirstTelegram |
private boolean |
_receivedProtocolId
Zeigt an ob die Protokoll-Id bereits empfangen wurde.
|
private long |
protocolId |
dataDescription, dav, incoming, object, receiver, requestId| Constructor and Description |
|---|
ProtocolAnswerReceiver(ClientDavInterface dav,
ClientApplication client,
long requestId,
boolean createProtocolRequest,
long timeout)
Erzeugt Senke für protokoll-bezogene Datensätze.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.Long |
getJobId()
Liefert die Auftrags-Id.
|
java.lang.Long |
getProtocolId()
Deprecated.
Diese Methode liefert nicht mehr die Protokoll-Id, sondern die eindeutige ID des protokollbezogenen Auftrags
|
private long |
time() |
protected void |
update(ResultData result)
Wird für jeden empfangenen Datensatz von
AnswerReceiver.update(ResultData[]) aufgerufen. |
void |
waitForAnswer(long timeoutMillis) |
hasData, subscribe, take, take, unsubscribe, updateprivate static final Debug _debug
private boolean _receivedProtocolId
private boolean _createProtocolRequest
true wenn der Receiver verwendet werden soll. (In diesem Fall erwartet der Empfänger als erstes Packet eine positive Quittung mit
Protokoll-Id.private long protocolId
private boolean _receivedFirstTelegram
public ProtocolAnswerReceiver(ClientDavInterface dav, ClientApplication client, long requestId, boolean createProtocolRequest, long timeout) throws ConfigurationException
dav - Verbindung zum Datenverteiler.client - Empfängerobjekt.requestId - Anfrage-Id.createProtocolRequest - true wenn der Receiver zum Empfang eines Protokolls verwendet werden soll. (In diesem Fall erwartet der Empfänger
als erstes Packet eine positive Quittung mit Protokoll-Id.timeout - Maximale Wartezeit, in der eine Antwort von der SWE Protokolle und Auswertungen eingehen muss.0 bedeutet: Unbegrenzte
Wartezeit. Achtung: Werden nur Online-Daten abgefragt, die selten auftreten (>timeout), oder müssen Archivdaten wieder
eingelagert werden, so kann es zu einem Timeout kommen, obwohl 'Protokolle und Auswertungen' arbeitet.ConfigurationException - Fehler beim Anmelden fü rDatenempfang.protected void update(ResultData result)
AnswerReceiverAnswerReceiver.update(ResultData[]) aufgerufen.update in class AnswerReceiverresult - Eingehender Datensatz. Enthält Daten, d.h. rd.getData() ist nicht null.public java.lang.Long getJobId()
null falls die Auftrags-Id unbekannt ist. Bei Protokoll-Erstellen-Aufträgen ist die Auftrags-ID
identisch zur Protokoll-Id.@Deprecated public final java.lang.Long getProtocolId()
null falls die Auftrags-Id unbekannt ist.public void waitForAnswer(long timeoutMillis)
throws java.lang.InterruptedException,
FailureException
java.lang.InterruptedExceptionFailureExceptionprivate long time()