From a491534489e3574d99b7782952a7e8885344025d Mon Sep 17 00:00:00 2001
From: yueye <768242801@qq.com>
Date: Tue, 4 Jul 2023 18:32:38 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BD=BF=E7=94=A8redisson?=
 =?UTF-8?q?=E9=98=9F=E5=88=97=E6=97=B6=E7=9A=84=E7=9B=91=E5=90=AC=E7=9B=B8?=
 =?UTF-8?q?=E5=85=B3=E6=B3=A8=E6=84=8F=E4=BA=8B=E9=A1=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ruoyi/demo/controller/queue/DelayedQueueController.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ruoyi-demo/src/main/java/com/ruoyi/demo/controller/queue/DelayedQueueController.java b/ruoyi-demo/src/main/java/com/ruoyi/demo/controller/queue/DelayedQueueController.java
index e6dbee863..1b8f1d370 100644
--- a/ruoyi-demo/src/main/java/com/ruoyi/demo/controller/queue/DelayedQueueController.java
+++ b/ruoyi-demo/src/main/java/com/ruoyi/demo/controller/queue/DelayedQueueController.java
@@ -38,6 +38,7 @@ public class DelayedQueueController {
         log.info("通道: {} 监听中......", queueName);
         // 项目初始化设置一次即可
         QueueUtils.subscribeBlockingQueue(queueName, (String orderNum) -> {
+            //注：如业务代码部分使用到了redis相关操作，需要将业务逻辑异步，否则将会报错：Sync methods can't be invoked from async/rx/reactive listeners
             // 观察接收时间
             log.info("通道: {}, 收到数据: {}", queueName, orderNum);
         });