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 <[email protected]>
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());
}
}
+
}