|
@@ -50,7 +50,6 @@ public class TaskService {
|
|
private static final HashMap<String,LinkedBlockingQueue<DelEcsVo>> openMap = new HashMap<>();
|
|
private static final HashMap<String,LinkedBlockingQueue<DelEcsVo>> openMap = new HashMap<>();
|
|
|
|
|
|
|
|
|
|
- @Async
|
|
|
|
public void sendMq() {
|
|
public void sendMq() {
|
|
checkCount();
|
|
checkCount();
|
|
List<MqSendLog> mqSendLogs = mqSendLogService.getNoSendMsg();
|
|
List<MqSendLog> mqSendLogs = mqSendLogService.getNoSendMsg();
|
|
@@ -136,7 +135,6 @@ public class TaskService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- @Async
|
|
|
|
public void openEcsList() {
|
|
public void openEcsList() {
|
|
try {
|
|
try {
|
|
HashMap<String, MqQueueConfig> queueMap = queueConfigService.getQueueMap();
|
|
HashMap<String, MqQueueConfig> queueMap = queueConfigService.getQueueMap();
|
|
@@ -196,7 +194,6 @@ public class TaskService {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
- @Async
|
|
|
|
public void delEcsList() {
|
|
public void delEcsList() {
|
|
try {
|
|
try {
|
|
if(delList.isEmpty()){
|
|
if(delList.isEmpty()){
|