String user = record.key();
Message message = record.value();
- switch(message.getType())
- {
- case ADD:
- addNumber(partition, user, (MessageAddNumber) message);
- break;
-
- case CALC:
- calculateSum(partition, user, (MessageCalculateSum) message);
- break;
- }
+ // TODO: JSON-Nachrichten verarbeiten
if (throttle.isPresent())
{