code: @Override
  	public boolean onActivityTimeout() throws Exception
      {
      	// Called by watchdog if queue is inactive
      	if (closed)
      		return true;
      	
      	if (getSize() == 0)
      		return false; // Queue is empty
      	
      	// Notify next consumer
      	notifyConsumer(null);
  
      	return false;
      }
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.utils.watchdog.ActiveObject#onActivityTimeout()