if (currentAlarm.hasExpired()) {
if (currentAlarm != null && currentAlarm.hasExpired()) { if (isDebugEnabled()) debug("An alarm expired");
  protected void execute() {    if (isDebugEnabled ())      debug (getName () + " : cycle called (a subscription changed)");    super.execute ();    if (currentAlarm.hasExpired()) {      bufferingThread.run();      if (!bufferingThread.anyTasksLeft()) {	// tell the world that we have completed	if (isInfoEnabled())	  info (getName () + " now quiescent.");	qService.setQuiescentState();      }    }  }