xiaoyi
4 天以前 f71dabccb0e4c2fa410683e6058eb906a7dbf094
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}",