wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add-rocker

Browse Source
This commit is contained in:
zhangran 2024-03-28 16:54:40 +08:00
parent 70737dd8b0
commit df830ed828
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/RocketMQEventConfiguration.java
View File

@ -43,7 +43,7 @@ public class RocketMQEventConfiguration {
private String getTopic(String topic) {
if (!StringUtils.isEmpty(topic)) {
topic = topic + "_" + profileActivity;
topic = "topic_"+topic + "_" + profileActivity;
}
return topic;
}

2
black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java
View File

@ -35,7 +35,7 @@ public class BlackProducer implements InitializingBean {
.shardingKey(String.valueOf(baseEntity.getId()))
.targetId(String.valueOf(baseEntity.getId()))
.targetType(mqEventEnum.getModel())
.eventCode(new Event.EventCode(mqEventEnum.getModel(), mqEventEnum.getTag()))
.eventCode(mqEventEnum.getEventCode())
.eventModule(mqEventEnum.getModel())
.eventName(mqEventEnum.getTag())
.operatorId(operatorId)