diff --git a/pom.xml b/pom.xml index d57e67d..ae23d48 100644 --- a/pom.xml +++ b/pom.xml @@ -12,12 +12,12 @@ nexus-releases Nexus Release Repository - http://192.168.1.13:8001/nexus/content/repositories/releases/ + http://192.168.1.22:8001/nexus/content/repositories/releases/ nexus-snapshots Nexus Snapshot Repository - http://192.168.1.13:8001/nexus/content/repositories/snapshots/ + http://192.168.1.22:8001/nexus/content/repositories/snapshots/ @@ -43,6 +43,11 @@ rocketmq-spring-boot-starter 2.2.3 + + com.njcn.platform + message-api + 1.0.0 + org.springframework.boot diff --git a/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java b/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java deleted file mode 100644 index d50e9f0..0000000 --- a/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.njcn.middle.rocket.domain; - -import cn.hutool.core.util.IdUtil; -import lombok.Data; - -import java.time.LocalDateTime; - -/** - * @author hongawen - * @version 1.0.0 - * @date 2023年08月04日 10:53 - */ -@Data -public abstract class BaseMessage { - - /** - * 业务键,用于RocketMQ控制台查看消费情况 - * 为了保证唯一性,使用雪花算法生成一个随机id - */ - protected String key = IdUtil.getSnowflake().nextIdStr(); - - /** - * 发送消息来源,用于排查问题 - */ - protected String source = ""; - - /** - * 发送时间 - */ - protected LocalDateTime sendTime = LocalDateTime.now(); - - /** - * 重试次数,用于判断重试次数,超过重试次数发送异常警告 - */ - protected Integer retryTimes = 0; -}