liu
2026-09-07 06c312e584b99df613728d5ea8b32df4e156f3cc
yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/sender/rocketmq/RocketMQWebSocketMessageConsumer.java
@@ -8,7 +8,7 @@
/**
 * {@link RocketMQWebSocketMessage} 广播消息的消费者,真正把消息发送出去
 *
 * @author 芋道源码
 * @author 超级管理员
 */
@RocketMQMessageListener( // 重点:添加 @RocketMQMessageListener 注解,声明消费的 topic
        topic = "${yudao.websocket.sender-rocketmq.topic}",