1.2.2

noear · Feb 27, 2024 · 69ef899 · 69ef899
1 parent 0942430
commit 69ef899
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/folkmq-parent/pom.xml b/folkmq-parent/pom.xml
@@ -19,7 +19,7 @@
         <java.version>1.8</java.version>
 
         <folkmq.version>1.2.2</folkmq.version>
-        <socketd.version>2.4.3</socketd.version>
+        <socketd.version>2.4.4</socketd.version>
         <snack3.version>3.2.88</snack3.version>
         <solon.version>2.7.1</solon.version>
 

diff --git a/folkmq/src/main/java/org/noear/folkmq/client/MqClientDefault.java b/folkmq/src/main/java/org/noear/folkmq/client/MqClientDefault.java
@@ -343,6 +343,9 @@ public CompletableFuture<Boolean> publishAsync(String topic, MqMessage message)
                     String messsage = "Client message publish confirm failed: " + r.dataAsString();
                     future.completeExceptionally(new FolkmqException(messsage));
                 }
+            }).thenError(err -> {
+                String messsage = "Client message publish confirm failed: " + err.getMessage();
+                future.completeExceptionally(new FolkmqException(messsage));
             });
         } else {
             //::Qos0
@@ -417,6 +420,9 @@ public CompletableFuture<Boolean> unpublishAsync(String topic, String tid) throw
                 String messsage = "Client message unpublish confirm failed: " + r.dataAsString();
                 future.completeExceptionally(new FolkmqException(messsage));
             }
+        }).thenError(err -> {
+            String messsage = "Client message unpublish confirm failed: " + err.getMessage();
+            future.completeExceptionally(new FolkmqException(messsage));
         });
 
         return future;