try { sp.getPersistenceManager().removeAllMessageData(name);    } catch (Exception e) { log.error("Failed to remove message data", e); }
   void addCoreDestination(Destination jmsDestination) throws JMSException   {      JBossDestination d = (JBossDestination)jmsDestination;      String name = d.getName();      boolean isQueue = d.isQueue();      Channel c = getCoreDestination(isQueue, name);      if (c != null)      {         throw new JMSException("Destination " + jmsDestination + " already exists");      }      ServerPeer sp = destinationManager.getServerPeer();      // TODO I am using LocalQueues for the time being, switch to distributed Queues      if (isQueue)      {         c = new Queue(name,                       sp.getMessageStore(),                       sp.getPersistenceManager(),                       sp.getTransactionManager());         queueMap.put(name, c);      }      else      {         // TODO I am using LocalTopics for the time being, switch to distributed Topics         c = new Topic(name,                       sp.getMessageStore(),                       sp.getPersistenceManager(),                       sp.getTransactionManager());         topicMap.put(name, c);      }   }