public void removeTopicListener()

in src/main/java/org/openvasp/client/service/impl/WhisperServiceImpl.java [181:198]

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

    public void removeTopicListener(
            @NonNull final Topic topic,
            long listenerId) {

        listenerRecordsLock.lock();
        try {
            val listenerRecord = listenerRecords.get(topic);
            if (listenerRecord != null) {
                listenerRecord.removeTopicListener(listenerId);
                if (listenerRecord.isEmpty()) {
                    listenerRecords.remove(topic);
                    listenerRecord.close();
                }
            }
        } finally {
            listenerRecordsLock.unlock();
        }
    }