public class FlowControlTask extends Object
ArchiveQueryTask
eingesetzten StreamMultiplexer
steuern. Die dazu
versandten Steuerungspakete werden vom InQueuesMgr
empfangen und dann von diesem Task an die entsprechenden Multiplexer
weitergeleitet.Constructor and Description |
---|
FlowControlTask(ArchiveManager archiveMgr)
Erzeugt einen neuen Flusskontroll-Task.
|
Modifier and Type | Method and Description |
---|---|
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.
|
public FlowControlTask(ArchiveManager archiveMgr)
aMgr
- Der Archiv-Managerrodl
- Ring-of-Death-ListenerinputData
- Warteschlange des Taskspublic void processFlowCtrl(ResultData resultData)
public void subscribe(SystemObject queryAppObj, int queryIdx, StreamMultiplexer mux)
queryAppObj
- Anfrage-Applikations-ObjektqueryIdx
- Anfrage-Indexmux
- StreamMultiplexerpublic void unsubscribe(SystemObject queryAppObj, int queryIdx)
queryAppObj
- Anfrage-Applikations-ObjektqueryIdx
- Anfrage-Index