From c47c396c987cef367329633c58373405a08a8168 Mon Sep 17 00:00:00 2001
From: gtl <2949451835@qq.com>
Date: Tue, 21 May 2024 22:41:40 +0800
Subject: [PATCH] =?UTF-8?q?feat:=E6=96=B0=E5=A2=9E=E9=93=BE=E8=B7=AF?=
 =?UTF-8?q?=E8=BF=BD=E8=B8=AA=E7=9A=84=E6=97=A5=E5=BF=97=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ruoyi/dataTransform/consumer/DataSourceConsumer.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ruoyi-modules/ruoyi-data_transform/ruoyi-data_transform-server/src/main/java/com/ruoyi/dataTransform/consumer/DataSourceConsumer.java b/ruoyi-modules/ruoyi-data_transform/ruoyi-data_transform-server/src/main/java/com/ruoyi/dataTransform/consumer/DataSourceConsumer.java
index 801bcfd..8bb4cbe 100644
--- a/ruoyi-modules/ruoyi-data_transform/ruoyi-data_transform-server/src/main/java/com/ruoyi/dataTransform/consumer/DataSourceConsumer.java
+++ b/ruoyi-modules/ruoyi-data_transform/ruoyi-data_transform-server/src/main/java/com/ruoyi/dataTransform/consumer/DataSourceConsumer.java
@@ -77,6 +77,7 @@ public class DataSourceConsumer {
      */
     @RabbitListener(queuesToDeclare = {@Queue(name = QueueConstants.DATASOURCE_DELETE_MESSAGE)})
     public void deleteConsumer(Message message, Channel channel) {
+
         DataSource dataSource = (DataSource) messageConverter.fromMessage(message);
         log.info("数据源移除消费者接收到消息，消息内容：{}", JSON.toJSONString(dataSource));
         // 获取消息的id