From 25f8d68e022b5392a44a514eab04a987fec76715 Mon Sep 17 00:00:00 2001 From: SravanThotakura05 <83568543+SravanThotakura05@users.noreply.github.com> Date: Wed, 17 Jul 2024 15:07:05 +0530 Subject: [PATCH] fix failing test --- .../outgoing/SolaceDirectMessageOutgoingChannel.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/quarkus-solace-messaging-connector/runtime/src/main/java/com/solace/quarkus/messaging/outgoing/SolaceDirectMessageOutgoingChannel.java b/quarkus-solace-messaging-connector/runtime/src/main/java/com/solace/quarkus/messaging/outgoing/SolaceDirectMessageOutgoingChannel.java index d6a3a1c..df25e77 100644 --- a/quarkus-solace-messaging-connector/runtime/src/main/java/com/solace/quarkus/messaging/outgoing/SolaceDirectMessageOutgoingChannel.java +++ b/quarkus-solace-messaging-connector/runtime/src/main/java/com/solace/quarkus/messaging/outgoing/SolaceDirectMessageOutgoingChannel.java @@ -81,11 +81,8 @@ public SolaceDirectMessageOutgoingChannel(Vertx vertx, SolaceConnectorOutgoingCo } this.publisher.setPublisherReadinessListener(() -> isPublisherReady = true); - this.publisher.setPublishFailureListener(failedPublishEvent -> { - OutboundMessage outboundMessage = failedPublishEvent.getMessage(); - SolaceLogging.log.errorf("Failed to publish direct message with application-message-id %s and correlation-id %s", - outboundMessage.getApplicationMessageId(), outboundMessage.getCorrelationId()); + SolaceLogging.log.error("Failed to publish direct message"); reportFailure(failedPublishEvent.getException()); }); } @@ -267,5 +264,4 @@ public void isAlive(HealthReport.HealthReportBuilder builder) { public void ready() { isPublisherReady = true; } - }