protected CoreDurableSubscription createDurableSubscriptionInternal(long id, String topicName,
protected DurableSubscription createDurableSubscriptionInternal(long id, String topicName,
   protected CoreDurableSubscription createDurableSubscriptionInternal(long id, String topicName,                                                                       String clientID,                                                                       String subscriptionName,                                                                        String selector,                                                                        boolean noLocal,                                                                                                                                   MessageStore ms,                                                                       PersistenceManager pm) throws Exception   {      Map subs = (Map)subscriptions.get(clientID);      if (subs == null)      {         subs = new ConcurrentReaderHashMap();         subscriptions.put(clientID, subs);      }            Topic topic = (Topic)getCoreDestinationInternal(false, topicName);            if (topic == null)      {         throw new javax.jms.IllegalStateException("Topic " + topicName + " is not loaded");      }            CoreDurableSubscription subscription =         new CoreDurableSubscription(id, clientID, subscriptionName, topic, selector, noLocal, ms, pm,                topic.getFullSize(), topic.getPageSize(), topic.getDownCacheSize());            subs.put(subscriptionName, subscription);            return subscription;   }   