联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
曾成
2020-05-14 753140881c427f333fc0e4fcd3abd4654cae90c0 
 UserService/src/main/java/com/java110/user/kafka/UserServiceKafka.java


@@ -1,18 +1,19 @@


package com.java110.user.kafka;




import com.alibaba.fastjson.JSONObject;


import com.java110.common.constant.KafkaConstant;


import com.java110.common.constant.ResponseConstant;


import com.java110.common.constant.StatusConstant;


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.utils.constant.KafkaConstant;


import com.java110.utils.constant.ResponseConstant;


import com.java110.utils.constant.StatusConstant;


import com.java110.utils.exception.InitConfigDataException;


import com.java110.utils.exception.InitDataFlowContextException;


import com.java110.utils.kafka.KafkaFactory;


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;