Package de.bsvrz.pua.prot.client
Class ProtocolAnswerReceiver
- java.lang.Object
-
- de.bsvrz.pua.prot.client.AnswerReceiver
-
- de.bsvrz.pua.prot.client.ProtocolAnswerReceiver
-
- All Implemented Interfaces:
de.bsvrz.dav.daf.main.ClientReceiverInterface
- Direct Known Subclasses:
ProtocolCompletionAnswerReceiver
public class ProtocolAnswerReceiver extends AnswerReceiver
Empfänger für protokoll-bezogene Antwortdatensätze von Pua. Der erste Antwortdatensatz von Pua enthält die Protokoll-Id, über die die Kommunikation ab diesem Punkt abgewickelt wird.
-
-
Field Summary
-
Fields inherited from class de.bsvrz.pua.prot.client.AnswerReceiver
dataDescription, dav, incoming, object, receiver, requestId
-
-
Constructor Summary
Constructors Constructor Description ProtocolAnswerReceiver(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.config.ClientApplication client, long requestId, boolean createProtocolRequest, long timeout)
Erzeugt Senke für protokoll-bezogene Datensätze.
-
Method Summary
Modifier and Type Method 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 Auftragsprotected void
update(de.bsvrz.dav.daf.main.ResultData result)
Wird für jeden empfangenen Datensatz vonAnswerReceiver.update(ResultData[])
aufgerufen.void
waitForAnswer(long timeoutMillis)
-
Methods inherited from class de.bsvrz.pua.prot.client.AnswerReceiver
hasData, subscribe, take, take, unsubscribe, update
-
-
-
-
Constructor Detail
-
ProtocolAnswerReceiver
public ProtocolAnswerReceiver(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.config.ClientApplication client, long requestId, boolean createProtocolRequest, long timeout) throws de.bsvrz.dav.daf.main.config.ConfigurationException
Erzeugt Senke für protokoll-bezogene Datensätze. Meldet sich sofort auf protokoll-bezogene Antwortdaten von PuA an.- Parameters:
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.- Throws:
de.bsvrz.dav.daf.main.config.ConfigurationException
- Fehler beim Anmelden fü rDatenempfang.
-
-
Method Detail
-
update
protected void update(de.bsvrz.dav.daf.main.ResultData result)
Description copied from class:AnswerReceiver
Wird für jeden empfangenen Datensatz vonAnswerReceiver.update(ResultData[])
aufgerufen.- Specified by:
update
in classAnswerReceiver
- Parameters:
result
- Eingehender Datensatz. Enthält Daten, d.h.rd.getData()
ist nichtnull
.
-
getJobId
public java.lang.Long getJobId()
Liefert die Auftrags-Id.- Returns:
- Auftrags-Id oder
null
falls die Auftrags-Id unbekannt ist. Bei Protokoll-Erstellen-Aufträgen ist die Auftrags-ID identisch zur Protokoll-Id.
-
getProtocolId
@Deprecated public final java.lang.Long getProtocolId()
Deprecated.Diese Methode liefert nicht mehr die Protokoll-Id, sondern die eindeutige ID des protokollbezogenen AuftragsLiefert die Auftrags-Id.- Returns:
- Auftrags-Id oder
null
falls die Auftrags-Id unbekannt ist.
-
waitForAnswer
public void waitForAnswer(long timeoutMillis) throws java.lang.InterruptedException, de.bsvrz.sys.funclib.losb.exceptions.FailureException
- Throws:
java.lang.InterruptedException
de.bsvrz.sys.funclib.losb.exceptions.FailureException
-
-