public class StreamedRequestManager
extends java.lang.Object
Diese Klasse verwaltet Archivantworten, die an unterschiedliche StreamedArchiveRequester gerichtet sind und sorgt dafür, dass jeder StreamedArchivRequester nur die Archivantworten bekommt, die für ihn sind. Somit werden die Antworten des Archivs nicht an alle StreamedArchiveRequester geschickt, sondern an diesen Manager und dieser verteilt die Antworten.
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 java.util.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 java.util.Map _streamedArchiveRequesterMap
Hier werden alle StreamedArchiveRequester gespeichert, als Key wird das Archivsystem genommen, das die Daten versendet. Das Archivsystem trägt sich selber in den Datensatz ein den es verschickt. Somit kann der Datensatz, der empfangen wird, wieder einem StreamedArchiveRequester zugeordnet werden.
private final ClientDavInterface _connection
Connection, über die Archivdaten für die Empfängerapplikation übertragen werden.
private static final Debug _debug
DebugLogger für Debug-Ausgaben
private final short _defaultSimulationVariant
public StreamedRequestManager(ClientDavInterface connection, short defaultSimulationVariant)
public StreamedArchiveRequester getArchiveRequester(SystemObject archiveSystem)
Diese Methode gibt ein StreamedArchiveRequester zurück, falls noch kein Objekt vorhanden ist, wird ein Objekt angelegt. Der StreamedArchiveRequester bekommt ein Archivsystem übergeben und kann somit Daten anfordern
archiveSystem
- Von diesem Archivsystem kann der StreamedArchiveRequester Daten anfordernprivate void subscribeReceiver() throws DataNotSubscribedException
Diese Methode meldet das StreamedRequestManager Objekt als Empfänger für Datensätze an. Die Datensätze werden vom Archive verschickt und sind für einen bestimmten StreamedArchiveRequester gedacht.
DataNotSubscribedException
- Senden von Datensätzen ohne entsprechende Sendeanmeldungenprivate void receivingData(Data data)
Diese Methode analysiert einen Datensatz und reicht diesen an den richtigen StreamedArchiveRequester weiter.
data
- Datensatz eines Archivs