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

     @Transactional(rollbackFor = Exception.class)
	 @Override
	 public ConsumerGroupTopicCreateResponse subscribe(ConsumerGroupTopicCreateRequest consumerGroupTopicCreateRequest) {
	     return subscribe(consumerGroupTopicCreateRequest, consumerGroupService.getCache());

     }

}