diff --git a/socket-api/src/main/java/cn/lili/scocket/listener/MessageSendListener.java b/socket-api/src/main/java/cn/lili/scocket/listener/MessageSendListener.java index a0b9e4e7..b4e33bd3 100644 --- a/socket-api/src/main/java/cn/lili/scocket/listener/MessageSendListener.java +++ b/socket-api/src/main/java/cn/lili/scocket/listener/MessageSendListener.java @@ -7,7 +7,6 @@ import cn.lili.modules.message.entity.dos.Message; import cn.lili.modules.message.entity.enums.MessageShowType; import cn.lili.modules.message.entity.vos.MessageShowVO; import cn.lili.modules.message.mapper.StoreMessageMapper; -import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; @@ -24,11 +23,11 @@ import org.springframework.web.bind.annotation.CrossOrigin; @Component @CrossOrigin @Slf4j - @RocketMQMessageListener(topic = "${lili.data.rocketmq.other-topic}", consumerGroup = "${lili.data.rocketmq.other-group}") public class MessageSendListener implements RocketMQListener { - private final StoreMessageMapper storeMessageMapper; + @Autowired + private StoreMessageMapper storeMessageMapper; @Autowired private SimpMessagingTemplate simpMessagingTemplate;