From ac4de7623b87a6826d3078f35cf3da13a43af3cf Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Thu, 26 Mar 2020 11:10:23 +0800
Subject: [PATCH] update
---
src/main/java/com/moral/task/RabbitMQInsertTask.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/moral/task/RabbitMQInsertTask.java b/src/main/java/com/moral/task/RabbitMQInsertTask.java
index 5e2cac5..55b2739 100644
--- a/src/main/java/com/moral/task/RabbitMQInsertTask.java
+++ b/src/main/java/com/moral/task/RabbitMQInsertTask.java
@@ -32,7 +32,7 @@
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
-//@Component
+@Component
public class RabbitMQInsertTask {
private static transient Logger logger = LoggerFactory.getLogger(RabbitMQInsertTask.class);
@@ -61,7 +61,7 @@
@Qualifier("organization_data")
private TopicExchange organization_data;
- //@XxlJob("RabbitMQRealtimeMinutely")
+ @XxlJob("RabbitMQRealtimeMinutely")
public ReturnT insertRabbitMQRealtimeMinutely(String params) {
LocalDateTime time = LocalDateTime.now();
int year = time.getYear();
@@ -122,7 +122,7 @@
return returnT;
}
- //@XxlJob("RabbitMQRealtimeEveryFiveMinutes")
+ @XxlJob("RabbitMQRealtimeEveryFiveMinutes")
public ReturnT insertRabbitMQRealtimeEveryFiveMinutes(String params) {
LocalDateTime time = LocalDateTime.now();
int year = time.getYear();
@@ -183,7 +183,7 @@
return returnT;
}
- //@XxlJob("RabbitMQMinutely")
+ @XxlJob("RabbitMQMinutely")
public ReturnT insertRabbitMQMinutely(String params) {
LocalDateTime time = LocalDateTime.now();
int year = time.getYear();
@@ -245,7 +245,7 @@
return returnT;
}
- //@XxlJob("RabbitMQHourly")
+ @XxlJob("RabbitMQHourly")
public ReturnT insertRabbitMQHourly(String params) {
LocalDateTime time = LocalDateTime.now();
Map organizationIdMap = JSON.parseObject(params);
@@ -302,7 +302,7 @@
return returnT;
}
- //@XxlJob("RabbitMQDaily")
+ @XxlJob("RabbitMQDaily")
public ReturnT insertRabbitMQDaily(String params) {
LocalDateTime time = LocalDateTime.now();
Map organizationIdMap = JSON.parseObject(params);
--
Gitblit v1.8.0