ServerConsumerEndpoint consumer = (ServerConsumerEndpoint)consumers.get(new Integer(consumerID));
if (trace) { log.trace(this + " processing cancel for message " + messageID + " from consumer " + consumerID); }  ServerConsumerEndpoint consumer = getConsumerEndpoint(consumerID);
   protected void cancel(long messageID, int consumerID) throws JMSException   {      ServerConsumerEndpoint consumer = (ServerConsumerEndpoint)consumers.get(new Integer(consumerID));      if (consumer == null)      {         throw new IllegalStateException("Cannot find consumer:" + consumerID);      }      consumer.cancelMessage(messageID);   }