public class TelegramAggregator<T extends DataTelegramInterface> extends Object
| Modifier and Type | Field and Description |
|---|---|
private static Debug |
_debug |
private Map<SubscriptionInfo,List<T>> |
_telegrams |
| Constructor and Description |
|---|
TelegramAggregator() |
| Modifier and Type | Method and Description |
|---|---|
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 Map<SubscriptionInfo,List<T extends DataTelegramInterface>> _telegrams
public List<T> aggregate(T telegram, SubscriptionInfo subscription)
telegram - subscription -