liu
4 天以前 19ea21b1994e6e86c5d46120dcb0ff0e7c49d291
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}",