Direct Messaging: Publish failed listener to track failures and updat…

…e health status
SolaceLabs · Jul 12, 2024 · 318f84c · 318f84c
1 parent 84fe6e5
commit 318f84c
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...c/main/java/com/solace/quarkus/messaging/outgoing/SolaceDirectMessageOutgoingChannel.java b/...c/main/java/com/solace/quarkus/messaging/outgoing/SolaceDirectMessageOutgoingChannel.java
@@ -207,6 +207,16 @@ private Uni<Object> publishMessage(DirectMessagePublisher publisher, Message<?>
                     //                        });
                     //                    } else {
                     publisher.publish(outboundMessage, topic.get());
+                    publisher.setPublishFailureListener(failedPublishEvent -> {
+                        PubSubPlusClientException exception = failedPublishEvent.getException();
+                        if (exception != null) {
+                            isPublishFailed = true;
+                            e.fail(exception);
+                        } else {
+                            publishedMessagesTracker.decrement();
+                            e.complete(null);
+                        }
+                    });
                     publishedMessagesTracker.decrement();
                     e.complete(null);
                     //                    }