ManageableTopic t = (ManageableTopic)cm.getCoreDestination(jbt); t.removeAllMessages();
org.jboss.messaging.core.local.Topic t = (org.jboss.messaging.core.local.Topic)cm.getCoreDestination(jbt);   Iterator iter = t.iterator(); while (iter.hasNext()) { Object sub = iter.next(); ((Subscription)sub).removeAllMessages(); }
   public void removeAllMessages() throws JMSException   {      if (!started)      {         log.warn("Topic is stopped.");         return;      }      JBossTopic jbt = new JBossTopic(name);      ManageableTopic t = (ManageableTopic)cm.getCoreDestination(jbt);      t.removeAllMessages();   }