ServerConsumerEndpoint consumer = (ServerConsumerEndpoint)consumers.get(consumerID);
ServerConsumerEndpoint consumer = (ServerConsumerEndpoint)consumers.get(Integer.valueOf(consumerID));
   void cancel(String messageID, String consumerID) throws JMSException   {      ServerConsumerEndpoint consumer = (ServerConsumerEndpoint)consumers.get(consumerID);      if (consumer == null)      {         throw new IllegalStateException("Cannot find consumer:" + consumerID);      }      consumer.cancelMessage(messageID);   }