Package de.bsvrz.ars.ars.mgmt.tasks
Class FlowControlTask
java.lang.Object
de.bsvrz.ars.ars.mgmt.tasks.FlowControlTask
public class FlowControlTask
extends java.lang.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.-
Constructor Summary
Constructors Constructor Description FlowControlTask()
Erzeugt einen neuen Flusskontroll-Task. -
Method Summary
Modifier and Type Method Description 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.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
FlowControlTask
public FlowControlTask()Erzeugt einen neuen Flusskontroll-Task.
-
-
Method Details
-
processFlowCtrl
public void processFlowCtrl(de.bsvrz.dav.daf.main.ResultData resultData) -
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.- Parameters:
queryAppObj
- Anfrage-Applikations-ObjektqueryIdx
- Anfrage-Indexmux
- 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.- Parameters:
queryAppObj
- Anfrage-Applikations-ObjektqueryIdx
- Anfrage-Index
-