public synchronized void addSubscriber()

in src/main/java/org/apache/sling/jms/impl/JMSTopicManager.java [131:138]


    public synchronized  void addSubscriber(ServiceReference<Subscriber> serviceRef) {
        if (registrations.containsKey(serviceRef)) {
            LOGGER.error("Registration for service reference is already present {}",serviceRef);
            return;
        }
        SubscriberHolder subscriberHolder = new SubscriberHolder(session, serviceRef.getBundle().getBundleContext().getService(serviceRef), getServiceProperties(serviceRef));
        registrations.put(serviceRef, subscriberHolder);
    }