caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

正确引入问题处理

Browse Source
This commit is contained in:
Chopper 2021-05-13 15:14:41 +08:00
parent a6b2b955e8
commit cf03a0dec5
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
socket-api/src/main/java/cn/lili/scocket/listener/MessageSendListener.java
View File

@ -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.enums.MessageShowType;
import cn.lili.modules.message.entity.vos.MessageShowVO; import cn.lili.modules.message.entity.vos.MessageShowVO;
import cn.lili.modules.message.mapper.StoreMessageMapper; import cn.lili.modules.message.mapper.StoreMessageMapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
@ -24,11 +23,11 @@ import org.springframework.web.bind.annotation.CrossOrigin;
@Component @Component
@CrossOrigin @CrossOrigin
@Slf4j @Slf4j
@RocketMQMessageListener(topic = "${lili.data.rocketmq.other-topic}", consumerGroup = "${lili.data.rocketmq.other-group}") @RocketMQMessageListener(topic = "${lili.data.rocketmq.other-topic}", consumerGroup = "${lili.data.rocketmq.other-group}")
public class MessageSendListener implements RocketMQListener<MessageExt> { public class MessageSendListener implements RocketMQListener<MessageExt> {
private final StoreMessageMapper storeMessageMapper; @Autowired
private StoreMessageMapper storeMessageMapper;
@Autowired @Autowired
private SimpMessagingTemplate simpMessagingTemplate; private SimpMessagingTemplate simpMessagingTemplate;