public long addTopicListener()

in src/main/java/org/openvasp/client/service/impl/WhisperServiceImpl.java [161:178]

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

    public long addTopicListener(
            @NonNull final Topic topic,
            @NonNull final EncryptionType encType,
            @NonNull final String key,
            @NonNull final TopicListener<ShhMessage> listener) {

        listenerRecordsLock.lock();
        try {
            TopicListenerRecord listenerRecord = listenerRecords.get(topic);
            if (listenerRecord == null) {
                listenerRecord = new TopicListenerRecord(topic, encType, key);
                listenerRecords.put(topic, listenerRecord);
            }
            return listenerRecord.addTopicListener(listener);
        } finally {
            listenerRecordsLock.unlock();
        }
    }