if (trace) { log.trace("activating consumer endpoint"); }
      public void run()      {         try         {            if (trace) { log.trace("activating consumer endpoint"); }            //consumerDelegate.activate();            MessageProxy m = (MessageProxy)consumerDelegate.getMessageNow(true);                        if (m != null)            {               handleMessage(m);            }         }         catch(Throwable t)         {            log.error("Consumer endpoint activation failed", t);            if (t.getCause() != null)            {               log.error("Cause:" + t.getCause());            }            stopReceiver();         }         finally         {            synchronized (activationLock)            {               activationCount.decrement();               activationLock.notifyAll();            }         }               } 