This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch fix/CAMEL-24069 in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0f78060f5a0e739dbe1fd2bf175989446f275d21 Author: Claus Ibsen <[email protected]> AuthorDate: Wed Jul 15 13:43:45 2026 +0200 CAMEL-24069: camel-spring-rabbitmq - Use consumer exception handler for async failures Co-Authored-By: Claude Opus 4.6 <[email protected]> Signed-off-by: Claus Ibsen <[email protected]> --- .../camel/component/springrabbit/EndpointMessageListener.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/components/camel-spring-parent/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java b/components/camel-spring-parent/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java index bd85fd309ff6..f9740674eca3 100644 --- a/components/camel-spring-parent/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java +++ b/components/camel-spring-parent/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java @@ -251,10 +251,8 @@ public class EndpointMessageListener implements ChannelAwareMessageListener { // method and rethrow it exchange.setException(rce); } else { - // we were done async, so use the endpoint error handler - if (endpoint.getExceptionHandler() != null) { - endpoint.getExceptionHandler().handleException(rce); - } + // we were done async, so use the consumer error handler + consumer.getExceptionHandler().handleException("Error processing exchange", exchange, rce); } }
