public class TelegramAggregator<T extends DataTelegramInterface>
extends java.lang.Object
Diese Klasse dient dazu, aufgeteilte Datentelegramme wieder zusammenzusetzen. Dazu ist für jedes ankommende Telegram die aggregate()-Funktion auszuführen. Sobald alle Telegramm eingetroffen sind, wird eine Liste mit den Telegrammen zurückgegeben, sonst nur eine leere Liste.
Modifier and Type | Field and Description |
---|---|
private static Debug |
_debug |
private java.util.Map<SubscriptionInfo,java.util.List<T>> |
_telegrams |
Constructor and Description |
---|
TelegramAggregator() |
Modifier and Type | Method and Description |
---|---|
java.util.List<T> |
aggregate(T telegram,
SubscriptionInfo subscription)
Verarbeitet ein ankommendes Telegramm und gibt die Liste der Telegramme zurück, sobald alle Telegramme eingetroffen sind.
|
private static final Debug _debug
private final java.util.Map<SubscriptionInfo,java.util.List<T extends DataTelegramInterface>> _telegrams
public java.util.List<T> aggregate(T telegram, SubscriptionInfo subscription)
Verarbeitet ein ankommendes Telegramm und gibt die Liste der Telegramme zurück, sobald alle Telegramme eingetroffen sind. Es ist daher wichtig, dass alle Telegramme einer Datenidentifikation in der richtigen Reihenfolge eintreffen. Um das zu erreichen sollte pro Anmeldung nur ein einzelner Thread Telegramme eintragen
telegram
- subscription
-