ServerPeer sp = destinationManager.getServerPeer(); try { sp.getPersistenceManager().removeAllMessageData(name);    } catch (Exception e) { log.error("Failed to remove message data", e); }
   Distributor removeCoreDestination(boolean isQueue, String name)   {      ServerPeer sp = destinationManager.getServerPeer();      try      {         sp.getPersistenceManager().removeAllMessageData(name);                  //FIXME - Also need to remove any message refs stored in memory for this destination               }      catch (Exception e)      {         log.error("Failed to remove message data", e);      }      if (isQueue)      {         return (Distributor)queueMap.remove(name);      }      else      {         return (Distributor)topicMap.remove(name);      }         }