if (log.isTraceEnabled()) { log.trace("activating consumer endpoint"); } consumerDelegate.activate();
if (trace) { log.trace("activating consumer endpoint"); }  MessageDelegate m = (MessageDelegate)consumerDelegate.getMessageNow(true);  if (m != null) { handleMessage(m); }
      public void run()      {         try         {            if (log.isTraceEnabled()) { log.trace("activating consumer endpoint"); }            consumerDelegate.activate();         }         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();            }         }               } 