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

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new ad46e399076 Polished
ad46e399076 is described below

commit ad46e3990768f321983509fac2c5ba0e7db99a0c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sun May 4 10:20:23 2025 +0200

    Polished
---
 .../component/google/pubsub/consumer/CamelMessageReceiver.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/CamelMessageReceiver.java
 
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/CamelMessageReceiver.java
index d7a267cc81d..8a123df7236 100644
--- 
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/CamelMessageReceiver.java
+++ 
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/consumer/CamelMessageReceiver.java
@@ -69,7 +69,11 @@ public class CamelMessageReceiver implements MessageReceiver 
{
         try {
             processor.process(exchange);
         } catch (Exception e) {
-            consumer.getExceptionHandler().handleException(e);
+            exchange.setException(e);
+        }
+        if (exchange.getException() != null) {
+            
consumer.getExceptionHandler().handleException(exchange.getException());
         }
     }
+
 }

Reply via email to