class ConsumerCommitServiceImpl implements ConsumerCommitService, BrokerTimerService {

	protected void clearOldData() {
		boolean flag = (System.currentTimeMillis() - lastTime - 10 * 60 * 1000) > 0;
		if (flag) {
			synchronized (lockObj) {
				if ((System.currentTimeMillis() - lastTime - 30 * 60 * 1000) > 0) {
					mapAppPolling.set(new ConcurrentHashMap<>(failMapAppPolling));
					failMapAppPolling.clear();
					lastTime = System.currentTimeMillis();
				}
			}
		}
	}

}