de.bsvrz.ars.ars.mgmt.tasks
Class FlowControlTask

java.lang.Object
  extended by 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.

Author:
beck et al. projects GmbH, Thomas Schaefer

Constructor Summary
FlowControlTask(ArchiveManager archiveMgr)
          Erzeugt einen neuen Flusskontroll-Task.
 
Method Summary
 void processFlowCtrl(ResultData resultData)
           
 void subscribe(SystemObject queryAppObj, int queryIdx, StreamMultiplexer mux)
          Registriert den angegebenen StreamMultiplexer fuer den Empfang von Steuerpaketen vom angegebenen Anfrage-Applikations-Objekt und Anfrage-Index, die dieser gerade mit einer Archivantwort versorgt.
 void unsubscribe(SystemObject queryAppObj, int queryIdx)
          De-Registriert den zuvor unter dem angegebenen Anfrage-Applikations-Objekt und Anfrage-Index registrierten StreamMultiplexer fuer den Empfang von Steuerpaketen.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FlowControlTask

public FlowControlTask(ArchiveManager archiveMgr)
Erzeugt einen neuen Flusskontroll-Task.

Parameters:
aMgr - Der Archiv-Manager
rodl - Ring-of-Death-Listener
inputData - Warteschlange des Tasks
Method Detail

processFlowCtrl

public void processFlowCtrl(ResultData resultData)

subscribe

public void subscribe(SystemObject queryAppObj,
                      int queryIdx,
                      StreamMultiplexer mux)
Registriert den angegebenen StreamMultiplexer fuer den Empfang von Steuerpaketen vom angegebenen Anfrage-Applikations-Objekt und Anfrage-Index, die dieser gerade mit einer Archivantwort versorgt.

Parameters:
queryAppObj - Anfrage-Applikations-Objekt
queryIdx - Anfrage-Index
mux - StreamMultiplexer

unsubscribe

public void unsubscribe(SystemObject queryAppObj,
                        int queryIdx)
De-Registriert den zuvor unter dem angegebenen Anfrage-Applikations-Objekt und Anfrage-Index registrierten StreamMultiplexer fuer den Empfang von Steuerpaketen.

Parameters:
queryAppObj - Anfrage-Applikations-Objekt
queryIdx - Anfrage-Index