Class 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.
    • 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 Auftrags
      protected void update​(de.bsvrz.dav.daf.main.ResultData result)
      Wird für jeden empfangenen Datensatz von AnswerReceiver.update(ResultData[]) aufgerufen.
      void waitForAnswer​(long timeoutMillis)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • 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 von AnswerReceiver.update(ResultData[]) aufgerufen.
        Specified by:
        update in class AnswerReceiver
        Parameters:
        result - Eingehender Datensatz. Enthält Daten, d.h. rd.getData() ist nicht null.
      • 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 Auftrags
        Liefert 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