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

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

public class SubscriptionArchiveOnlineDataManager
extends Object

Diese Klasse stellt ein Objekt zur Verfügung, das Archidaten und Onlinedaten mischt. Dafür meldet es sich als Empfänger auf vorgegebene Daten an und fordert dann aus dem Archivsystem ebenfalls Daten an um diese zu mischen.

Author:
Kappich+Kniß Systemberatung Aachen (K2S), Achim Wullenkord (AW)

Nested Class Summary
private static class SubscriptionArchiveOnlineDataManager.ArchiveDataRequester
          Klasse, die Archivdaten anfordert und diese vor einen Onlinedatensatz einmischt
private  class SubscriptionArchiveOnlineDataManager.Receiver
          Objekt, das Onlinedaten puffert oder durchreicht, es stellt ebenfalls den ersten Online verfügbaren Datensatz zur Verfügung.
private static class SubscriptionArchiveOnlineDataManager.ReceiverKey
          Stellt ein Objekt für eine HashMap zur Verfügung
 
Field Summary
private  ArchiveRequestManager _archive
          Objekt, über das Archivanfragen gestellt werden können.
private  ClientDavInterface _connection
          Wird zum an/abmelden der Datenidentifikationen benötigt
private static Debug _debug
          DebugLogger für Debug-Ausgaben
private  Map<SubscriptionArchiveOnlineDataManager.ReceiverKey,SubscriptionArchiveOnlineDataManager.Receiver> _receiverList
          Speichert alle Objekte, die als Empfänger angemeldet sind
 
Constructor Summary
SubscriptionArchiveOnlineDataManager(ArchiveRequestManager archive, ClientDavInterface connection)
          Erzeugt ein Objekt, das es ermöglicht einen Empfänger anzumelden.
 
Method Summary
 void subscribe(DatasetReceiverInterface receiver, SystemObject object, DataDescription dataDescription, ReceiveOptions options, HistoryTypeParameter historyType, long history)
          Meldet sich als Empfänger von Datensätzen an und stellt über das Objekt receiver die Daten (Archivdaten+Online) zur Verfügung.
 void unsubscribe(DatasetReceiverInterface receiver, SystemObject object, DataDescription dataDescription)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_receiverList

private final Map<SubscriptionArchiveOnlineDataManager.ReceiverKey,SubscriptionArchiveOnlineDataManager.Receiver> _receiverList
Speichert alle Objekte, die als Empfänger angemeldet sind


_archive

private final ArchiveRequestManager _archive
Objekt, über das Archivanfragen gestellt werden können. Wird benötigt um Archivdaten vor den Onlinestrom zu mischen


_connection

private final ClientDavInterface _connection
Wird zum an/abmelden der Datenidentifikationen benötigt


_debug

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

Constructor Detail

SubscriptionArchiveOnlineDataManager

public SubscriptionArchiveOnlineDataManager(ArchiveRequestManager archive,
                                            ClientDavInterface connection)
Erzeugt ein Objekt, das es ermöglicht einen Empfänger anzumelden. Vor die Onlinedatensätze werden Archidatensätze gemischt.

Parameters:
archive - Archiv, das die Archivdaten zur Verfügung stellt
connection - Verbindung zum DaV
Method Detail

subscribe

public void subscribe(DatasetReceiverInterface receiver,
                      SystemObject object,
                      DataDescription dataDescription,
                      ReceiveOptions options,
                      HistoryTypeParameter historyType,
                      long history)
               throws ConfigurationException
Meldet sich als Empfänger von Datensätzen an und stellt über das Objekt receiver die Daten (Archivdaten+Online) zur Verfügung.

Parameters:
receiver -
object -
dataDescription -
options -
historyType -
history -
Throws:
ConfigurationException

unsubscribe

public void unsubscribe(DatasetReceiverInterface receiver,
                        SystemObject object,
                        DataDescription dataDescription)
                 throws ConfigurationException
Throws:
ConfigurationException