warn (getName () + " restarting thread " + getBufferingThread() + " for " + name);
warn (getName () + " re-examining unprocessed tasks.");
    public synchronized void expire() {      if (!expired) {	synchronized (alarmMutex) { // getSubtasks will check to see if one exists, so must synchronize	  currentAlarm = null;	}	expired = true;	String name = getName()+"_restartThread";	if (isWarnEnabled())	  warn (getName () + " restarting thread " + getBufferingThread() + 		" for " + name);	schedulable = 	  threadService.getThread (this, 				   new Runnable () {				       public void run() {					 // review the known task list					 processTasks (new ArrayList(myInputTaskCallback.getSubscription().getCollection()));				       }				     }, 				   name);	schedulable.start();      }    }