public class TelegramAggregator<T extends DataTelegramInterface> extends Object
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.
|
public List<T> aggregate(T telegram, SubscriptionInfo subscription)
telegram
- subscription
-