From 5268a2b7dfa556bd6f5a2d5e446cea3ea9940c10 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期三, 22 四月 2020 11:18:23 +0800
Subject: [PATCH] add 分发 master_author 添加字段 subscribe increment， 添加7个表 master_author_subscribe master_author_unactive sys_dispense_config sys_dispense_logs sys_view sys_view_join sys_view_logic
---
src/main/java/com/highdatas/mdm/util/TimeTasks.java | 60 ++++++++++++++++++++++++++----------------------------------
1 files changed, 26 insertions(+), 34 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/util/TimeTasks.java b/src/main/java/com/highdatas/mdm/util/TimeTasks.java
index 8547b5d..e67e744 100644
--- a/src/main/java/com/highdatas/mdm/util/TimeTasks.java
+++ b/src/main/java/com/highdatas/mdm/util/TimeTasks.java
@@ -1,16 +1,8 @@
package com.highdatas.mdm.util;
-import com.highdatas.mdm.service.DispenseService;
-import com.highdatas.mdm.util.pool.MqMessage;
import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
-import org.springframework.scheduling.annotation.Scheduled;
-
-import java.io.IOException;
-import java.util.Date;
-import java.util.concurrent.PriorityBlockingQueue;
/**
* @author kimi
@@ -23,31 +15,31 @@
@EnableScheduling
@Slf4j
public class TimeTasks {
- @Autowired
- DispenseService dispenseService;
+// @Autowired
+// DispenseService dispenseService;
- @Scheduled(fixedRate=1000 * 10)
- private void configureTasks() {
- PriorityBlockingQueue<Runnable> queue = dispenseService.getQueue();
- if (queue.isEmpty()) {
- return;
- }
- log.info("queue passiveQueueSize: {}", queue.size());
- for (Runnable runnable : queue) {
- if (!(runnable instanceof MqMessage)) {
- continue;
- }
- MqMessage mqMessage = (MqMessage) runnable;
- Date endTime = mqMessage.getEndTime();
- Date now = new Date();
- if (now.after(endTime)) {
- //timeout;
- try {
- mqMessage.printTimeOut();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- }
+// @Scheduled(fixedRate=1000 * 10)
+// private void configureTasks() {
+// PriorityBlockingQueue<Runnable> queue = dispenseService.getQueue();
+// if (queue.isEmpty()) {
+// return;
+// }
+// log.info("queue passiveQueueSize: {}", queue.size());
+// for (Runnable runnable : queue) {
+// if (!(runnable instanceof MqMessage)) {
+// continue;
+// }
+// MqMessage mqMessage = (MqMessage) runnable;
+// Date endTime = mqMessage.getEndTime();
+// Date now = new Date();
+// if (now.after(endTime)) {
+// //timeout;
+// try {
+// mqMessage.printTimeOut();
+// } catch (IOException e) {
+// e.printStackTrace();
+// }
+// }
+// }
+// }
}
--
Gitblit v1.8.0