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