de.bsvrz.dav.daf.main.impl.archive.request
Class StreamedRequestManager

java.lang.Object
  extended by de.bsvrz.dav.daf.main.impl.archive.request.StreamedRequestManager

public class StreamedRequestManager
extends 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.

Author:
Kappich Systemberatung

Nested Class Summary
private  class StreamedRequestManager.ClientReceiver
          Diese Klasse implementiert ein ClientReceiverInterface.
 
Field Summary
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 Summary
StreamedRequestManager(ClientDavInterface connection, short defaultSimulationVariant)
           
 
Method Summary
 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.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_streamedArchiveRequesterMap

private final 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.


_connection

private final ClientDavInterface _connection
Connection, über die Archivdaten für die Empfängerapplikation übertragen werden.


_debug

private static final Debug _debug
DebugLogger für Debug-Ausgaben


_defaultSimulationVariant

private final short _defaultSimulationVariant
Constructor Detail

StreamedRequestManager

public StreamedRequestManager(ClientDavInterface connection,
                              short defaultSimulationVariant)
Method Detail

getArchiveRequester

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

Parameters:
archiveSystem - Von diesem Archivsystem kann der StreamedArchiveRequester Daten anfordern
Returns:
StreamedArchiveRequester zum anfordern von Daten aus einem Archivsystem

subscribeReceiver

private 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.

Throws:
DataNotSubscribedException - Senden von Datensätzen ohne entsprechende Sendeanmeldungen

receivingData

private void receivingData(Data data)
Diese Methode analysiert einen Datensatz und reicht diesen an den richtigen StreamedArchiveRequester weiter.

Parameters:
data - Datensatz eines Archivs