diff --git a/pom.xml b/pom.xml index 4b69fd171..6bb04485d 100644 --- a/pom.xml +++ b/pom.xml @@ -511,7 +511,7 @@ org.apache.rocketmq rocketmq-client - 4.8.0 + 5.3.2 provided diff --git a/src/main/java/io/jboot/components/mq/rocketmq/JbootRocketmqImpl.java b/src/main/java/io/jboot/components/mq/rocketmq/JbootRocketmqImpl.java index 5d0ed0873..3dbea0971 100644 --- a/src/main/java/io/jboot/components/mq/rocketmq/JbootRocketmqImpl.java +++ b/src/main/java/io/jboot/components/mq/rocketmq/JbootRocketmqImpl.java @@ -32,7 +32,7 @@ import org.apache.rocketmq.common.consumer.ConsumeFromWhere; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.common.message.MessageExt; -import org.apache.rocketmq.common.protocol.heartbeat.MessageModel; +import org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel; import java.util.Map;