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, update
private 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)
AnswerReceiver
AnswerReceiver.update(ResultData[])
aufgerufen.update
in class AnswerReceiver
result
- 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.InterruptedException
FailureException
private long time()