private void processIncomingMassage()

in src/main/java/org/openvasp/client/service/impl/WhisperServiceImpl.java [303:316]

• 14 lines of code
• 4 McCabe index (conditional complexity)

    private void processIncomingMassage(@NonNull final ShhMessage whisperMessage) {
        val topic = new Topic(whisperMessage.getTopic());
        try {
            val listenerRecord = listenerRecords.get(topic);
            if (listenerRecord != null) {
                listenerRecord.onTopicEvent(new TopicEvent<>(topic, whisperMessage));
            }
        } catch (WhisperIOException ex) {
            throw ex;
        } catch (VaspException ex) {
            log.error("Error of processing a Whisper incoming message at the topic " + topic, ex);
            exceptionHandler.processException(ex);
        }
    }