private void topicPollingLoop()

in src/main/java/org/openvasp/client/service/impl/WhisperServiceImpl.java [262:282]

• 21 lines of code
• 7 McCabe index (conditional complexity)

    private void topicPollingLoop() {
        log.debug("{} started", Thread.currentThread().getName());
        try {
            while (!Thread.interrupted() && checkState(RUNNING)) {
                pollMessages();
                Thread.sleep(POLL_TIMEOUT);
            }
        } catch (InterruptedException ex) {
            Thread.currentThread().interrupt();
        } catch (WhisperIOException ex) {
            val cause = ex.getCause();
            if (!(cause instanceof InterruptedIOException)) {
                log.error(formatErrorMessage(), ex);
            }
        } catch (Exception ex) {
            log.error(formatErrorMessage(), ex);
        } finally {
            setTerminatedState();
            log.debug("{} terminated", Thread.currentThread().getName());
        }
    }