diff --git a/rocketmq-v5-client-spring-boot-samples/pom.xml b/rocketmq-v5-client-spring-boot-samples/pom.xml index 02b00837..1a147f66 100644 --- a/rocketmq-v5-client-spring-boot-samples/pom.xml +++ b/rocketmq-v5-client-spring-boot-samples/pom.xml @@ -38,6 +38,7 @@ 1.8 1.8 2.2.4-SNAPSHOT + 1.3.0 @@ -47,6 +48,11 @@ rocketmq-v5-client-spring-boot-starter ${rocketmq-v5-client-spring-boot-starter-version} + + commons-logging + commons-logging + ${commons-logging-version} + diff --git a/rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-producer-demo/src/main/java/org/apache/rocketmq/samples/springboot/ClientProducerApplication.java b/rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-producer-demo/src/main/java/org/apache/rocketmq/samples/springboot/ClientProducerApplication.java index f03df016..98ae39fd 100644 --- a/rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-producer-demo/src/main/java/org/apache/rocketmq/samples/springboot/ClientProducerApplication.java +++ b/rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-producer-demo/src/main/java/org/apache/rocketmq/samples/springboot/ClientProducerApplication.java @@ -73,14 +73,14 @@ public static void main(String[] args) { @Override public void run(String... args) throws ClientException { - testASycSendMessage(); + testAsyncSendMessage(); testSendDelayMessage(); testSendFIFOMessage(); testSendNormalMessage(); testSendTransactionMessage(); } - void testASycSendMessage() { + void testAsyncSendMessage() { CompletableFuture future0 = new CompletableFuture<>(); CompletableFuture future1 = new CompletableFuture<>();