public synchronized void deactivate()

in src/main/java/org/apache/sling/jms/impl/JMSQueueManager.java [87:94]

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

    public synchronized void deactivate() throws JMSException {
        for ( Map.Entry<ServiceReference<QueueReader>, QueueReaderHolder> e : registrations.entrySet()) {
            e.getValue().close();
        }
        registrations.clear();
        connection.stop();
        connection.close();
    }