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.LonggetJobId()Liefert die Auftrags-Id.java.lang.LonggetProtocolId()Deprecated.Diese Methode liefert nicht mehr die Protokoll-Id, sondern die eindeutige ID des protokollbezogenen Auftragsprotected voidupdate(de.bsvrz.dav.daf.main.ResultData result)Wird für jeden empfangenen Datensatz vonAnswerReceiver.update(ResultData[])aufgerufen.voidwaitForAnswer(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.ConfigurationExceptionErzeugt 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-truewenn 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.0bedeutet: 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:AnswerReceiverWird für jeden empfangenen Datensatz vonAnswerReceiver.update(ResultData[])aufgerufen.- Specified by:
updatein 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
nullfalls 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
nullfalls 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.InterruptedExceptionde.bsvrz.sys.funclib.losb.exceptions.FailureException
-
-