(rocketmq-spring) branch master updated: Update remoting client version to 5.3.2 to support go-away (#714)

[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 fb044e2  Update remoting client version to 5.3.2 to support go-away 
(#714)
fb044e2 is described below

commit fb044e2e4746360ae6bbe4dc89ab2c263eb76d81
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Wed Mar 19 21:17:52 2025 +0800

    Update remoting client version to 5.3.2 to support go-away (#714)
    
    * update remoting client version to 5.3.2 to support go-away
    
    * Fix RocketMQTemplateTest can not pass
    
    ---------
    
    Co-authored-by: RongtongJin <jinrongton...@mails.ucas.ac.cn>
---
 rocketmq-spring-boot-parent/pom.xml                                   | 2 +-
 .../java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/rocketmq-spring-boot-parent/pom.xml 
b/rocketmq-spring-boot-parent/pom.xml
index e772450..93ecee7 100644
--- a/rocketmq-spring-boot-parent/pom.xml
+++ b/rocketmq-spring-boot-parent/pom.xml
@@ -42,7 +42,7 @@
 
         
<rocketmq.spring.boot.version>2.3.4-SNAPSHOT</rocketmq.spring.boot.version>
 
-        <rocketmq.version>5.3.1</rocketmq.version>
+        <rocketmq.version>5.3.2</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/test/java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java
 
b/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java
index 256345a..2777b82 100644
--- 
a/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java
+++ 
b/rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java
@@ -126,8 +126,8 @@ public class RocketMQTemplateTest {
     public void testReceiveMessage() {
         try {
             rocketMQTemplate.receive(String.class);
-        } catch (MessagingException e) {
-            
assertThat(e).hasMessageContaining("org.apache.rocketmq.remoting.exception.RemotingConnectException:
 connect to [127.0.0.1:9876] failed");
+        } catch (IllegalStateException e) {
+            assertThat(e).hasMessageContaining("The consumer not running, 
please start it first");
         }
     }