From a251582ac37942cb76bdbf1bdf8c7b9b8ab883c2 Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Sun, 23 Apr 2023 15:59:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/qniao/iot/IotMonitoringDataJob.java    | 3 ++-
 src/main/java/com/qniao/iot/constant/ConfigConstant.java | 2 ++
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
index 4108c0b..d7638cd 100644
--- a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
+++ b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
@@ -427,7 +427,8 @@ public class IotMonitoringDataJob {
 
                             @Override
                             public String computeRoutingKey(DeviceMonitoringData data) {
-                                return null;
+
+                                return ApolloConfig.getStr(ConfigConstant.SINK_RABBITMQ_ROUTING_KEY);
                             }
 
                             @Override
diff --git a/src/main/java/com/qniao/iot/constant/ConfigConstant.java b/src/main/java/com/qniao/iot/constant/ConfigConstant.java
index 63a8975..46d39ac 100644
--- a/src/main/java/com/qniao/iot/constant/ConfigConstant.java
+++ b/src/main/java/com/qniao/iot/constant/ConfigConstant.java
@@ -39,4 +39,6 @@ public interface ConfigConstant {
     String SINK_RABBITMQ_PASSWORD = "sink.rabbitmq.password";
 
     String SINK_RABBITMQ_EXCHANGE = "sink.rabbitmq.exchange";
+
+    String SINK_RABBITMQ_ROUTING_KEY = "sink.rabbitmq.routingKey";
 }