activationCount.decrement();
synchronized (activationLock) { activationCount.decrement(); activationLock.notifyAll(); }
      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         {            activationCount.decrement();         }               } 