try { this.serverPeer.getPersistenceManager().removeAllMessageData(subscription.getQueue().getChannelID()); } catch (Exception e) { final String msg = "Failed to remove message data for durable subscription"; log.error(msg, e); throw new JMSException(msg); }
   public void unsubscribe(String subscriptionName) throws JMSException   {      if (subscriptionName == null)      {         throw new InvalidDestinationException("Destination is null");      }      DurableSubscriptionHolder subscription = this.serverPeer.getClientManager().            removeDurableSubscription(this.connectionEndpoint.clientID, subscriptionName);      if (subscription == null)      {         throw new InvalidDestinationException("Cannot find durable subscription with name " +            subscriptionName + " to unsubscribe");      }      subscription.getTopic().remove(subscription.getQueue());         }