de.bsvrz.pua.prot.processing.onlinebuffer
Class OnlineDataReceiverSet

java.lang.Object
  extended by de.bsvrz.pua.prot.processing.onlinebuffer.OnlineDataReceiverSet

public class OnlineDataReceiverSet
extends java.lang.Object

Verwaltet Anmeldungen zum Abgreifen von Online-Daten. Alle vom Set erzeugten Empfänger haben den gleichen Zeitbereich und die gleichen Optionen (Normal oder Delta-Daten, nachgelieferte Daten). Es wird nur ein neuer Empfänger erzeugt, wenn es noch keinen Empfänger für die jeweilige Datenidentifikation gibt. Alle Empfänger werden als einfahce Empfänger erzeugt (nicht als Senke). Der OnlineDataReceiver erzeugt genau einen Empfänger je Datenidentifikation.

Version:
$Revision: 1.2 $ / $Date: 2008/01/22 16:55:49 $ / ($Author: yvonnes $)
Author:
beck et al. projects GmbH, Martin Hilgers

Constructor Summary
OnlineDataReceiverSet(ClientDavInterface dav, ReceiveOptions receiveOptions, java.util.List<Tuple<java.lang.Long,java.lang.Long>> periodList, NewDataCollector newDataCollector)
          Erzeugt das Objekt.
 
Method Summary
 OnlineDataReceiver createReceiver(Qualifier qualifier)
          Gibt einen Empfänger für die übergebende Datenidentifikation zurück.
 boolean dataAvailable()
          Zeigt ob Daten für einen der Empfänger vorliegen.
protected  ClientDavInterface getDav()
          Liefert Verbindung zum Dav.
protected  java.util.List<Tuple<java.lang.Long,java.lang.Long>> getPeriods()
          Liefert eine Liste mit Zeitbereichen.
 ReceiveOptions getReceiveOptions()
          Liefert die Empfangsoptionen.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

OnlineDataReceiverSet

public OnlineDataReceiverSet(ClientDavInterface dav,
                             ReceiveOptions receiveOptions,
                             java.util.List<Tuple<java.lang.Long,java.lang.Long>> periodList,
                             NewDataCollector newDataCollector)
                      throws FailureException
Erzeugt das Objekt.

Parameters:
dav - Verbindung zum Datenverteiler
receiveOptions - Anmeldeoptionen. (delta-Anfrage, nachgelieferte Daten). Siehe auch Klassenbeschreibung für weitere Informationen.
periodList - Liste mit relevanten Zeitbereichen. Wird nicht verändert. Siehe auch Klassenbeschreibung für weitere Informationen.
newDataCollector - Objekt, das benachrichtigt wird, wenn neue Daten vorliegen.
Throws:
FailureException - Falls es bei der Kommunikation mit der Konfiguration zu einem Fehler kommt.
Method Detail

createReceiver

public OnlineDataReceiver createReceiver(Qualifier qualifier)
                                  throws FailureException
Gibt einen Empfänger für die übergebende Datenidentifikation zurück.

Parameters:
qualifier - Datenidentifikation.
Returns:
Empfänger für die übergebene Datenidentifikation.
Throws:
FailureException - Falls es bei der Kommunikation mit der Konfiguration zu einem Fehler kommt.

getDav

protected ClientDavInterface getDav()
Liefert Verbindung zum Dav. Diese Verbindung darf vom einem Aufrufer nicht beendet (ClientDavInterface#disconnect(boolean, java.lang.String)) werden!

Returns:
Verbindung zum Dav.

getPeriods

protected java.util.List<Tuple<java.lang.Long,java.lang.Long>> getPeriods()
Liefert eine Liste mit Zeitbereichen. Diese Liste darf nicht verändert werden! INFO Immutable machen (mittels Collections.unmodifiableCollection).Tupel muss dann aber auch daran angepasst werden.

Returns:
Liste der relevanten Zeitbereiche.

getReceiveOptions

public ReceiveOptions getReceiveOptions()
Liefert die Empfangsoptionen.

Returns:
Empfangsoptionen.

dataAvailable

public boolean dataAvailable()
Zeigt ob Daten für einen der Empfänger vorliegen.

Returns:
true falls noch Daten für einen Empfänger vorliegen.


Copyright © 2005-2008 beck et al. projects GmbH All Rights Reserved.