public void close()

in src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueProviderImpl.java [101:116]

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

    public void close() {
        PubQueueCache queueCache = this.cache;
        if (queueCache != null) {
            queueCache.close();
        }
        if (reg != null) {
            try {
                reg.unregister();
                reg = null;
            } catch (Exception e) {
                LOG.info(e.getMessage(), e);
            }
        }
        IOUtils.closeQuietly(queuedNotifier);
        LOG.info("Stopped Publisher queue provider service");
    }