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()); } } + }