From cf03a0dec517150e2750034e93f8b0e7b86ad8b9 Mon Sep 17 00:00:00 2001 From: Chopper Date: Thu, 13 May 2021 15:14:41 +0800 Subject: [PATCH] =?UTF-8?q?=E6=AD=A3=E7=A1=AE=E5=BC=95=E5=85=A5=E9=97=AE?= =?UTF-8?q?=E9=A2=98=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/lili/scocket/listener/MessageSendListener.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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;