You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/08/07 16:49:13 UTC

[camel] 01/02: CAMEL-19685: increase logging in camel-mock

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 134cc113d43da184477a140467d90649225e6ae9
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Aug 1 11:21:50 2023 +0200

    CAMEL-19685: increase logging in camel-mock
---
 .../org/apache/camel/component/mock/MockEndpoint.java   | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
index 383f01db318..353b8fc08cf 100644
--- a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
+++ b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
@@ -1814,10 +1814,27 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
 
     protected void assertEquals(String message, Object expectedValue, Object actualValue) {
         if (!ObjectHelper.equal(expectedValue, actualValue)) {
+            logReceivedExchanges();
+
             fail(message + ". Expected: <" + expectedValue + "> but was: <" + actualValue + ">");
         }
     }
 
+    private void logReceivedExchanges() {
+        for (Exchange exchange : receivedExchanges) {
+            LOG.warn("Received exchange: {}", exchange);
+            final Message exchangeMessage = exchange.getMessage();
+            if (exchangeMessage != null) {
+                LOG.warn("Received exchange message: {}", exchangeMessage);
+                final Object body = exchangeMessage.getBody();
+                if (body != null) {
+                    LOG.warn("Received exchange message body: {}", body);
+                    LOG.warn("Received exchange message body type: {}", body.getClass());
+                }
+            }
+        }
+    }
+
     /**
      * Asserts that the given {@code predicate} is {@code true}, if not an {@code AssertionError} is raised with the
      * give message.