联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
wuxw
2019-02-02 9454b49eeabd56894550f1419f14e96f9d10c2ef 
 UserService/src/main/java/com/java110/user/kafka/UserServiceKafka.java


@@ -7,12 +7,13 @@


import com.java110.common.exception.InitConfigDataException;


import com.java110.common.exception.InitDataFlowContextException;


import com.java110.common.kafka.KafkaFactory;


import com.java110.core.base.AppBase;


import com.java110.core.base.controller.BaseController;


import com.java110.core.context.BusinessServiceDataFlow;


import com.java110.core.factory.DataTransactionFactory;


import com.java110.user.smo.IUserServiceSMO;


import org.apache.kafka.clients.consumer.ConsumerRecord;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.kafka.annotation.KafkaListener;




@@ -25,6 +26,8 @@


 */


public class UserServiceKafka extends BaseController {




    private final static Logger logger = LoggerFactory.getLogger(UserServiceKafka.class);




    @Autowired


    private IUserServiceSMO userServiceSMOImpl;