public synchronized void deactivate()

in src/main/java/org/apache/sling/jms/impl/JMSTopicManager.java [88:98]

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

    public synchronized  void deactivate() throws JMSException {
        for ( Map.Entry<ServiceReference<Subscriber>, SubscriberHolder> e : registrations.entrySet()) {
            e.getValue().close();
        }
        registrations.clear();
        // don't close the session, there is a bug in JMS which means an already closed session wont go quietly
        // and the hook that shutsdown an embedded connection still gets fired when OSGi shutsdown even with
        // a flag to prevent it. connection.stop and close are clean.
        connection.stop();
        connection.close();
    }