Skip to content

Commit fb044e2

Browse files
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 <[email protected]>
1 parent e1bc04d commit fb044e2

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

rocketmq-spring-boot-parent/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242

4343
<rocketmq.spring.boot.version>2.3.4-SNAPSHOT</rocketmq.spring.boot.version>
4444

45-
<rocketmq.version>5.3.1</rocketmq.version>
45+
<rocketmq.version>5.3.2</rocketmq.version>
4646
<slf4j.version>1.7.25</slf4j.version>
4747
<jackson.version>2.11.1</jackson.version>
4848
<fastjson.version>1.2.83</fastjson.version>

rocketmq-spring-boot/src/test/java/org/apache/rocketmq/spring/core/RocketMQTemplateTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,8 @@ public void testAsyncBatchSendMessage() {
126126
public void testReceiveMessage() {
127127
try {
128128
rocketMQTemplate.receive(String.class);
129-
} catch (MessagingException e) {
130-
assertThat(e).hasMessageContaining("org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [127.0.0.1:9876] failed");
129+
} catch (IllegalStateException e) {
130+
assertThat(e).hasMessageContaining("The consumer not running, please start it first");
131131
}
132132
}
133133

0 commit comments

Comments
 (0)