|
|
@@ -3,6 +3,7 @@ package com.dragon.tj.portal.component.message;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.dragon.tj.portal.common.constants.BusinessConstants;
|
|
|
import com.dragon.tj.portal.common.convert.mesage.MessageReqConvert;
|
|
|
import com.dragon.tj.portal.common.convert.notice.NoticeReqConvert;
|
|
|
import com.dragon.tj.portal.common.dto.message.MessageInfoSend;
|
|
|
@@ -83,7 +84,7 @@ public class MessageConsumer {
|
|
|
ack.acknowledge();
|
|
|
}
|
|
|
|
|
|
- @KafkaListener(topicPattern = "sseTopic.*")
|
|
|
+ @KafkaListener(topicPattern = BusinessConstants.TOPIC_PRE + ".*")
|
|
|
public void sseConnectionProcess2(String msg, Acknowledgment ack) {
|
|
|
log.info("get kafka2 msg from topic:{}, msg:{}", KafkaInitialConfiguration.sseTopic, msg);
|
|
|
if (StrUtil.isEmpty(msg)) {
|
caiaa1