huminmin
7 天以前 0fdd0bf60b7d98d21c9b5ff95bb55f0fa6495007
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}",