public class StreamedRequestManager extends Object
Modifier and Type | Class and Description |
---|---|
private class |
StreamedRequestManager.ClientReceiver
Diese Klasse implementiert ein ClientReceiverInterface.
|
Modifier and Type | Field and Description |
---|---|
private ClientDavInterface |
_connection
Connection, über die Archivdaten für die Empfängerapplikation übertragen werden.
|
private static Debug |
_debug
DebugLogger für Debug-Ausgaben
|
private short |
_defaultSimulationVariant |
private Map |
_streamedArchiveRequesterMap
Hier werden alle StreamedArchiveRequester gespeichert, als Key wird das Archivsystem genommen, das die Daten versendet.
|
Constructor and Description |
---|
StreamedRequestManager(ClientDavInterface connection,
short defaultSimulationVariant) |
Modifier and Type | Method and Description |
---|---|
StreamedArchiveRequester |
getArchiveRequester(SystemObject archiveSystem)
Diese Methode gibt ein StreamedArchiveRequester zurück, falls noch kein Objekt vorhanden ist, wird ein Objekt angelegt.
|
private void |
receivingData(Data data)
Diese Methode analysiert einen Datensatz und reicht diesen an den richtigen StreamedArchiveRequester weiter.
|
private void |
subscribeReceiver()
Diese Methode meldet das StreamedRequestManager Objekt als Empfänger für Datensätze an.
|
private final Map _streamedArchiveRequesterMap
private final ClientDavInterface _connection
private static final Debug _debug
private final short _defaultSimulationVariant
public StreamedRequestManager(ClientDavInterface connection, short defaultSimulationVariant)
public StreamedArchiveRequester getArchiveRequester(SystemObject archiveSystem)
archiveSystem
- Von diesem Archivsystem kann der StreamedArchiveRequester Daten anfordernprivate void subscribeReceiver() throws DataNotSubscribedException
DataNotSubscribedException
- Senden von Datensätzen ohne entsprechende Sendeanmeldungenprivate void receivingData(Data data)
data
- Datensatz eines Archivs