Klasse FlowControlTask

java.lang.Object
de.bsvrz.ars.ars.mgmt.tasks.FlowControlTask

public class FlowControlTask extends Object
KLasse zur Verarbeitung der Steuerungspakete, die von anderen Applikationen zur Flusskontrolle an das Archivsystem geschickt werden. Der Empfaenger einer Archivantwort kann den Sendefluss des im ArchiveQueryTask eingesetzten StreamMultiplexer steuern. Die dazu versandten Steuerungspakete werden vom InQueuesMgr empfangen und dann von diesem Task an die entsprechenden Multiplexer weitergeleitet.
  • Konstruktorübersicht

    Konstruktoren
    Konstruktor
    Beschreibung
    Erzeugt einen neuen Flusskontroll-Task.
  • Methodenübersicht

    Modifizierer und Typ
    Methode
    Beschreibung
    void
    processFlowCtrl(de.bsvrz.dav.daf.main.ResultData resultData)
     
    void
    subscribe(de.bsvrz.dav.daf.main.config.SystemObject queryAppObj, int queryIdx, de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer mux)
    Registriert den angegebenen StreamMultiplexer für den Empfang von Steuerpaketen vom angegebenen Anfrage-Applikations-Objekt und Anfrage-Index, die dieser gerade mit einer Archivantwort versorgt.
    void
    unsubscribe(de.bsvrz.dav.daf.main.config.SystemObject queryAppObj, int queryIdx)
    De-Registriert den zuvor unter dem angegebenen Anfrage-Applikations-Objekt und Anfrage-Index registrierten StreamMultiplexer für den Empfang von Steuerpaketen.

    Von Klasse geerbte Methoden java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Konstruktordetails

    • FlowControlTask

      public FlowControlTask()
      Erzeugt einen neuen Flusskontroll-Task.
  • Methodendetails

    • processFlowCtrl

      public void processFlowCtrl(de.bsvrz.dav.daf.main.ResultData resultData)
      Siehe auch:
    • subscribe

      public void subscribe(de.bsvrz.dav.daf.main.config.SystemObject queryAppObj, int queryIdx, de.bsvrz.sys.funclib.communicationStreams.StreamMultiplexer mux)
      Registriert den angegebenen StreamMultiplexer für den Empfang von Steuerpaketen vom angegebenen Anfrage-Applikations-Objekt und Anfrage-Index, die dieser gerade mit einer Archivantwort versorgt.
      Parameter:
      queryAppObj - Anfrage-Applikations-Objekt
      queryIdx - Anfrage-Index
      mux - StreamMultiplexer
    • unsubscribe

      public void unsubscribe(de.bsvrz.dav.daf.main.config.SystemObject queryAppObj, int queryIdx)
      De-Registriert den zuvor unter dem angegebenen Anfrage-Applikations-Objekt und Anfrage-Index registrierten StreamMultiplexer für den Empfang von Steuerpaketen.
      Parameter:
      queryAppObj - Anfrage-Applikations-Objekt
      queryIdx - Anfrage-Index