in dynamic-router-eip/dynamic-router-eip-stack/main-router/src/main/java/org/apache/camel/example/springboot/numbers/mainrouter/service/NumberStatisticsService.java [49:60]
public void updateStats(final String body) {
try {
CommandMessage message = objectMapper.readValue(body, CommandMessage.class);
long now = System.currentTimeMillis();
long newTime = now - start;
long elapsed = currentMs.updateAndGet(cv -> Math.max(cv, newTime));
countsMap.put("elapsed seconds", elapsed / 1000);
message.params().forEach((key, val) -> countsMap.merge(key, Long.parseLong(val), Math::max));
} catch (JsonProcessingException e) {
LOG.warn("Error when trying to update number statistics", e);
}
}