fix failing test

SolaceLabs · Jul 17, 2024 · 25f8d68 · 25f8d68
1 parent 320798c
commit 25f8d68
Showing 1 changed file with 1 addition and 5 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
@@ -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;
     }
-
 }