public synchronized void addReader()

in src/main/java/org/apache/sling/jms/impl/JMSQueueManager.java [144:151]

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

    public synchronized  void addReader(ServiceReference<QueueReader> serviceRef) {
        if (registrations.containsKey(serviceRef)) {
            LOGGER.error("Registration for service reference is already present {}",serviceRef);
            return;
        }
        QueueReaderHolder queueReaderHolder = new QueueReaderHolder(connection, serviceRef.getBundle().getBundleContext().getService(serviceRef), getServiceProperties(serviceRef));
        registrations.put(serviceRef, queueReaderHolder);
    }