void consumeNewQuoteAndBroadcast()

in serverless-workflow-examples/serverless-workflow-loanbroker-showcase/loanbroker-ui/src/main/java/org/acme/loanbroker/NewQuoteSocket.java [51:60]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    void consumeNewQuoteAndBroadcast(QuotesResponse quotes) throws JsonProcessingException {
        LOGGER.info("Broadcasting a new quote response {}", quotes);
        for (Session s : sessions) {
            s.getAsyncRemote().sendText(mapper.writeValueAsString(quotes), result -> {
                if (result.getException() != null) {
                    LOGGER.error("Failed to broadcast message with contents {}", quotes, result.getException());
                }
            });
        }
    }