diff --git a/rocketmq-spring-boot-parent/pom.xml b/rocketmq-spring-boot-parent/pom.xml index e772450c..93ecee77 100644 --- a/rocketmq-spring-boot-parent/pom.xml +++ b/rocketmq-spring-boot-parent/pom.xml @@ -42,7 +42,7 @@ 2.3.4-SNAPSHOT - 5.3.1 + 5.3.2 1.7.25 2.11.1 1.2.83 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 256345ac..2777b825 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 testAsyncBatchSendMessage() { 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"); } }