public synchronized void addConsumer()

in src/main/java/org/apache/sling/jobs/impl/JobSubsystem.java [131:138]

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

    public synchronized  void addConsumer(ServiceReference<JobConsumer> serviceRef) {
        if (registrations.containsKey(serviceRef)) {
            LOGGER.error("Registration for service reference is already present {}",serviceRef);
            return;
        }
        JobConsumerHolder jobConsumerHolder = new JobConsumerHolder(serviceRef.getBundle().getBundleContext().getService(serviceRef), serviceRef);
        registrations.put(serviceRef, jobConsumerHolder);
    }