fix 线程池问题
This commit is contained in:
@@ -38,9 +38,6 @@ import org.springframework.util.CollectionUtils;
|
|||||||
import java.text.SimpleDateFormat;
|
import java.text.SimpleDateFormat;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.concurrent.CompletableFuture;
|
|
||||||
import java.util.concurrent.ExecutionException;
|
|
||||||
import java.util.concurrent.Executor;
|
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@@ -92,8 +89,6 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
|
|||||||
@Autowired
|
@Autowired
|
||||||
private AiAnalyticBusinessConfigMapper aiAnalyticBusinessConfigMapper;
|
private AiAnalyticBusinessConfigMapper aiAnalyticBusinessConfigMapper;
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private Executor getAsyncExecutor;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 处理Mq消息
|
* 处理Mq消息
|
||||||
|
|||||||
Reference in New Issue
Block a user