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);
}