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; } - }