[rocketmq-spring] branch master updated: [ISSUE #530] Upgrade rocketmq client version to 5.1.0 (#531)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new 8af8b8d  [ISSUE #530] Upgrade rocketmq client version to 5.1.0 (#531)
8af8b8d is described below

commit 8af8b8d9914e1f5e7f7f014204691c087b16862e
Author: mxsm <ljbm...@gmail.com>
AuthorDate: Mon Feb 27 08:26:47 2023 +0800

    [ISSUE #530] Upgrade rocketmq client version to 5.1.0 (#531)
    
    * [ISSUE #530]upgrade rocketmq client version to 5.1.0
    
    * fix compile error
---
 rocketmq-spring-boot-parent/pom.xml                                   | 2 +-
 .../rocketmq/spring/support/DefaultRocketMQListenerContainer.java     | 4 ++--
 .../main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java    | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/rocketmq-spring-boot-parent/pom.xml 
b/rocketmq-spring-boot-parent/pom.xml
index 59a5d37..102238f 100644
--- a/rocketmq-spring-boot-parent/pom.xml
+++ b/rocketmq-spring-boot-parent/pom.xml
@@ -40,7 +40,7 @@
 
         
<rocketmq.spring.boot.version>2.2.4-SNAPSHOT</rocketmq.spring.boot.version>
 
-        <rocketmq.version>5.0.0</rocketmq.version>
+        <rocketmq.version>5.1.0</rocketmq.version>
         <slf4j.version>1.7.25</slf4j.version>
         <jackson.version>2.11.1</jackson.version>
         <fastjson.version>1.2.83</fastjson.version>
diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
index 30e7135..0233a61 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
@@ -650,10 +650,10 @@ public class DefaultRocketMQListenerContainer implements 
InitializingBean,
         consumer.setInstanceName(instanceName);
         switch (messageModel) {
             case BROADCASTING:
-                
consumer.setMessageModel(org.apache.rocketmq.common.protocol.heartbeat.MessageModel.BROADCASTING);
+                
consumer.setMessageModel(org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel.BROADCASTING);
                 break;
             case CLUSTERING:
-                
consumer.setMessageModel(org.apache.rocketmq.common.protocol.heartbeat.MessageModel.CLUSTERING);
+                
consumer.setMessageModel(org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel.CLUSTERING);
                 break;
             default:
                 throw new IllegalArgumentException("Property 'messageModel' 
was wrong.");
diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
index a8abfda..0136fc3 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
@@ -304,10 +304,10 @@ public class RocketMQUtil {
 
         switch (messageModel) {
             case BROADCASTING:
-                
litePullConsumer.setMessageModel(org.apache.rocketmq.common.protocol.heartbeat.MessageModel.BROADCASTING);
+                
litePullConsumer.setMessageModel(org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel.BROADCASTING);
                 break;
             case CLUSTERING:
-                
litePullConsumer.setMessageModel(org.apache.rocketmq.common.protocol.heartbeat.MessageModel.CLUSTERING);
+                
litePullConsumer.setMessageModel(org.apache.rocketmq.remoting.protocol.heartbeat.MessageModel.CLUSTERING);
                 break;
             default:
                 throw new IllegalArgumentException("Property 'messageModel' 
was wrong.");