소스 검색

fix: 消费服务
1.开发消费成功后发kafka

luoyb 9 달 전
부모
커밋
7084ce7d90
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      ruoyi-server/ruoyi-server-consume/src/main/java/org/dromara/server/consume/business/BaseBusiness.java

+ 1 - 1
ruoyi-server/ruoyi-server-consume/src/main/java/org/dromara/server/consume/business/BaseBusiness.java

@@ -430,7 +430,7 @@ public class BaseBusiness {
      */
     public void completeUploadRecord(ConsumptionBo bo, RemoteUserAccountVo accountVo) {
         // 消费记录上传完成,还有一些后续工作,不需要知道处理结果,采用异步任务提交
-        // threadPoolTaskExecutor.execute(() -> sendConsumeToKafka(bo, accountVo));
+         threadPoolTaskExecutor.execute(() -> sendConsumeToKafka(bo, accountVo));
         //taskExecutor.submit(() -> sendCloudConsume(bo));
     }