You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2025/03/19 13:17:57 UTC
(rocketmq-spring) branch master updated: Update remoting client version to 5.3.2 to support go-away (#714)
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 <wu...@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 <ji...@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");
}
}