private void pollMessages()

in src/main/java/org/openvasp/client/service/impl/WhisperServiceImpl.java [284:301]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    private void pollMessages() {
        final List<ShhMessage> incomingMessages;

        listenerRecordsLock.lock();
        try {
            incomingMessages = listenerRecords.values()
                    .stream()
                    .map(TopicListenerRecord::getFilterId)
                    .flatMap(this::getWhisperMessages)
                    .collect(toList());
        } finally {
            listenerRecordsLock.unlock();
        }

        for (val message : incomingMessages) {
            processIncomingMassage(message);
        }
    }