class ConsumerGroupTopicServiceImpl extends AbstractBaseService<ConsumerGroupTopicEntity> implements CacheUpdateService, ConsumerGroupTopicService, TimerService {

	@Override
	public void start() {
		if (startFlag.compareAndSet(false, true)) {
			updateCache();
			executor.submit(new Runnable() {
				@Override
				public void run() {
					while (isRunning) {
						try {
							updateCache();
						} catch (Exception e) {
							log.error("ConsumerGroupTopicService_updateCache_error", e);
						}
						Util.sleep(soaConfig.getMqConsumerGroupTopicCacheInterval());
					}
				}
			});
		}
	}

}