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 <jinrongtong16@mails.ucas.ac.cn>
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 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");
}
}
