opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-21 02:25:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

添加使用redisson队列时的监听相关注意事项

Browse Source
This commit is contained in:
yueye 2023-07-04 18:32:38 +08:00
parent 775bd5925a
commit a491534489
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ruoyi-demo/src/main/java/com/ruoyi/demo/controller/queue/DelayedQueueController.java
View File

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