Class OnlineDataReceiverSet
- java.lang.Object
-
- 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 einfache Empfänger erzeugt (nicht als Senke). Der OnlineDataReceiver erzeugt genau einen Empfänger je Datenidentifikation.
-
-
Constructor Summary
Constructors Constructor Description OnlineDataReceiverSet(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, java.util.List<de.bsvrz.sys.funclib.losb.util.Tuple<java.lang.Long,java.lang.Long>> periodList, NewDataCollector newDataCollector, de.bsvrz.dav.daf.accessControl.UserInfo userInfo)
Erzeugt das Objekt.
-
Method Summary
Modifier and Type Method Description OnlineDataReceiver
createReceiver(ReferenceQualifier 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 java.util.List<de.bsvrz.sys.funclib.losb.util.Tuple<java.lang.Long,java.lang.Long>>
getPeriods()
Liefert eine Liste mit Zeitbereichen.de.bsvrz.dav.daf.main.ReceiveOptions
getReceiveOptions()
Liefert die Empfangsoptionen.
-
-
-
Constructor Detail
-
OnlineDataReceiverSet
public OnlineDataReceiverSet(de.bsvrz.dav.daf.main.ClientDavInterface dav, de.bsvrz.dav.daf.main.ReceiveOptions receiveOptions, java.util.List<de.bsvrz.sys.funclib.losb.util.Tuple<java.lang.Long,java.lang.Long>> periodList, NewDataCollector newDataCollector, de.bsvrz.dav.daf.accessControl.UserInfo userInfo)
Erzeugt das Objekt.- Parameters:
dav
- Verbindung zum DatenverteilerreceiveOptions
- 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.userInfo
-
-
-
Method Detail
-
createReceiver
public OnlineDataReceiver createReceiver(ReferenceQualifier qualifier) throws de.bsvrz.sys.funclib.losb.exceptions.FailureException
Gibt einen Empfänger für die übergebende Datenidentifikation zurück.- Parameters:
qualifier
- Datenidentifikation.- Returns:
- Empfänger für die übergebene Datenidentifikation.
- Throws:
de.bsvrz.sys.funclib.losb.exceptions.FailureException
- Falls es bei der Kommunikation mit der Konfiguration zu einem Fehler kommt.
-
getPeriods
protected java.util.List<de.bsvrz.sys.funclib.losb.util.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 de.bsvrz.dav.daf.main.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.
-
-