From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/util/mq/rocket/RocketMQUtil.java | 50 +++++++++++++++++++++++++-------------------------
1 files changed, 25 insertions(+), 25 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/mq/rocket/RocketMQUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/mq/rocket/RocketMQUtil.java
index 2e3251c..056a5a3 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/mq/rocket/RocketMQUtil.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/mq/rocket/RocketMQUtil.java
@@ -1,25 +1,25 @@
-package com.yeshi.fanli.util.mq.rocket;
-
-public class RocketMQUtil {
- // "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h";
- private static int[] DELAYS_S = new int[] { 1, 5, 10, 30, 60, 120, 180, 240, 300, 420, 480, 540, 600, 1200, 1800,
- 3600, 7200 };
-
- /**
- * 鑾峰彇寤舵椂绛夌骇
- * @Title: getDelayLevel
- * @Description:
- * @param s
- * @return
- * Integer 杩斿洖绫诲瀷
- * @throws
- */
- public static Integer getDelayLevel(int s) {
- for (int i=0;i<DELAYS_S.length;i++) {
- if(DELAYS_S[i]==s)
- return i+1;
- }
- return null;
- }
-
-}
+package com.yeshi.fanli.util.mq.rocket;
+
+public class RocketMQUtil {
+ // "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h";
+ private static int[] DELAYS_S = new int[] { 1, 5, 10, 30, 60, 120, 180, 240, 300, 420, 480, 540, 600, 1200, 1800,
+ 3600, 7200 };
+
+ /**
+ * 鑾峰彇寤舵椂绛夌骇
+ * @Title: getDelayLevel
+ * @Description:
+ * @param s
+ * @return
+ * Integer 杩斿洖绫诲瀷
+ * @throws
+ */
+ public static Integer getDelayLevel(int s) {
+ for (int i=0;i<DELAYS_S.length;i++) {
+ if(DELAYS_S[i]==s)
+ return i+1;
+ }
+ return null;
+ }
+
+}
--
Gitblit v1.8.0