public void updateStats()

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);
        }
    }