{"id":2088,"date":"2026-02-01T02:15:37","date_gmt":"2026-01-31T13:15:37","guid":{"rendered":"https:\/\/www.ronella.xyz\/?p=2088"},"modified":"2026-02-01T02:15:37","modified_gmt":"2026-01-31T13:15:37","slug":"apache-camel-error-handling-defaulterrorhandler-and-onexception","status":"publish","type":"post","link":"https:\/\/www.ronella.xyz\/?p=2088","title":{"rendered":"Apache Camel Error Handling: DefaultErrorHandler and onException"},"content":{"rendered":"

Apache Camel's robust error handling ensures reliable integration routes even when failures occur. The DefaultErrorHandler provides automatic retries and logging, while onException clauses offer precise control over specific exceptions.<\/p>\n

Core Concepts<\/h2>\n

DefaultErrorHandler<\/strong> is Camel\u2019s default strategy for all routes, featuring retry logic, detailed logging, and flexible recovery paths. It logs exceptions at ERROR level by default and supports configurable redeliveries without requiring dead letter channels. <\/p>\n

onException<\/strong> clauses intercept specific exception types globally or per-route, with priority based on exception specificity\u2014most-derived classes match first. Use handled(true)<\/code> to stop propagation and transform responses, or continued(true)<\/code> to resume the route.<\/p>\n

DefaultErrorHandler Configuration<\/h2>\n

Set global retry policies early in RouteBuilder\u2019s configure()<\/code> method:<\/p>\n

errorHandler(defaultErrorHandler()\n    .maximumRedeliveries(3)\n    .redeliveryDelay(2000)\n    .retryAttemptedLogLevel(LoggingLevel.WARN)\n    .logStackTrace(true));<\/code><\/pre>\n
Key options control retry behavior: maximumRedeliveries<\/code> caps attempts, redeliveryDelay<\/code> sets wait time (with exponential backoff), and retryAttemptedLogLevel<\/code> adjusts retry logging verbosity. Per-route overrides nest within from()<\/code> endpoints for granular control.<\/p>\n
onException Best Practices<\/h2>\n
Place onException handlers before route definitions for global scope. Multiple handlers for the same exception type chain by priority, with conditions via onWhen()<\/code>:<\/p>\n
onException(IOException.class)\n    .handled(true)\n    .log("\ud83d\udea8 IO EXCEPTION: ${exception.message}")\n    .to("direct:ioErrorHandler");\n\nonException(IllegalArgumentException.class)\n    .onWhen(exchange -> "high".equals(exchange.getIn().getHeader("error.priority")))\n    .handled(true)\n    .log("\u26a0\ufe0f HIGH PRIORITY: ${exception.message}");<\/code><\/pre>\n
The handled(true)<\/code> flag clears the exception and prevents DefaultErrorHandler retries unless continued(true)<\/code> is specified. Route to dedicated error flows like direct:ioErrorHandler<\/code> for consistent processing.<\/p>\n
Example<\/h2>\n
This self-contained demo showcases layered error handling across exception types, conditional logic, and retry policies:<\/p>\n
import org.apache.camel.*;\nimport org.apache.camel.builder.RouteBuilder;\nimport org.apache.camel.impl.DefaultCamelContext;\n\npublic class CamelErrorHandlingDemo extends RouteBuilder {\n\n    @Override\n    public void configure() throws Exception {\n        \/\/ Global DefaultErrorHandler with retries\n        errorHandler(defaultErrorHandler()\n            .maximumRedeliveries(3)\n            .redeliveryDelay(2000)\n            .retryAttemptedLogLevel(LoggingLevel.WARN)\n            .logStackTrace(true));\n\n        \/\/ Specific exception handlers (priority: most specific first)\n        onException(java.io.IOException.class)\n            .handled(true)\n            .log("\ud83d\udea8 IO EXCEPTION HANDLED FIRST: ${exception.message}")\n            .to("direct:ioErrorHandler");\n\n        onException(IllegalArgumentException.class)\n            .maximumRedeliveries(2)\n            .redeliveryDelay(1000)\n            .onWhen(exchange -> "high".equals(exchange.getIn().getHeader("error.priority")))\n            .handled(true)\n            .log("\u26a0\ufe0f HIGH PRIORITY ARG EXCEPTION: ${exception.message}")\n            .to("direct:argErrorHandler");\n\n        onException(IllegalArgumentException.class)\n            .handled(true)\n            .log("\u26a0\ufe0f DEFAULT ARG EXCEPTION: ${exception.message}")\n            .to("direct:argErrorHandler");\n\n        onException(Exception.class)\n            .handled(true)\n            .log("\ud83d\udc80 GENERIC EXCEPTION: ${exception.message}")\n            .to("direct:deadLetterQueue");\n\n        \/\/ Main processing route\n        from("direct:start")\n            .routeId("mainRoute")\n            .log("Processing: ${body}")\n            .process(mainProcessor())\n            .to("direct:success");\n\n        from("direct:success").log("\u2705 SUCCESS: ${body}");\n        from("direct:ioErrorHandler").log("\ud83d\udcc1 IO Error handled").setBody(constant("IO_PROCESSED"));\n        from("direct:argErrorHandler").log("\ud83d\udd04 Arg error processed").setBody(constant("ARG_PROCESSED"));\n        from("direct:deadLetterQueue").log("\u26b0\ufe0f DLQ: ${exception.stacktrace}").setBody(constant("DLQ_PROCESSED"));\n    }\n\n    private static Processor mainProcessor() {\n        return exchange -> {\n            String input = exchange.getIn().getBody(String.class);\n            switch (input != null ? input : "") {\n                case "io-fail":\n                    exchange.getIn().setHeader("error.priority", "high");\n                    throw new java.io.IOException("\ud83d\udcbe Disk full");\n                case "arg-high":\n                    exchange.getIn().setHeader("error.priority", "high");\n                    throw new IllegalArgumentException("\u274c High priority invalid data");\n                case "arg-normal":\n                    throw new IllegalArgumentException("\u274c Normal invalid data");\n                case "generic-fail":\n                    throw new RuntimeException("Unknown error");\n                default:\n                    exchange.getIn().setBody("\u2705 Processed: " + input);\n            }\n        };\n    }\n\n    public static void main(String[] args) throws Exception {\n        try (CamelContext context = new DefaultCamelContext()) {\n            context.getCamelContextExtension().setName("CamelErrorDemo");\n            context.addRoutes(new CamelErrorHandlingDemo());\n            context.start();\n\n            ProducerTemplate template = context.createProducerTemplate();\n            System.out.println("\ud83d\ude80 Camel Error Handling Demo...\\n");\n\n            template.sendBody("direct:start", "io-fail");      \/\/ \u2192 IO handler\n            template.sendBody("direct:start", "arg-high");     \/\/ \u2192 High priority arg\n            template.sendBody("direct:start", "arg-normal");   \/\/ \u2192 Default arg  \n            template.sendBody("direct:start", "generic-fail"); \/\/ \u2192 Generic handler\n            template.sendBody("direct:start", "good");         \/\/ \u2192 Success\n\n            Thread.sleep(8000);\n        }\n    }\n}<\/code><\/pre>\n
Expected Demo Output<\/h2>\n
textProcessing: io-fail\n\ud83d\udea8 IO EXCEPTION HANDLED FIRST: \ud83d\udcbe Disk full\n\ud83d\udcc1 IO Error handled\n\nProcessing: arg-high  \n\u26a0\ufe0f HIGH PRIORITY ARG EXCEPTION: \u274c High priority invalid data\n\ud83d\udd04 Arg error processed<\/code><\/pre>\n
Production Tips<\/h2>\n
Test all failure paths during development using predictable payloads like the demo. Monitor exchange.getProperty(Exchange.REDELIVERY_COUNTER)<\/code> for retry stats. For complex flows, combine with doTry().doCatch()<\/code> blocks for local exception handling within routes. This approach scales from simple REST APIs to enterprise integration patterns.<\/p>\n","protected":false},"excerpt":{"rendered":"
Apache Camel’s robust error handling ensures reliable integration routes even when failures occur. The DefaultErrorHandler provides automatic retries and logging, while onException clauses offer precise control over specific exceptions. Core Concepts DefaultErrorHandler is Camel\u2019s default strategy for all routes, featuring retry logic, detailed logging, and flexible recovery paths. It logs exceptions at ERROR level by […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[92],"tags":[],"_links":{"self":[{"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=\/wp\/v2\/posts\/2088"}],"collection":[{"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=2088"}],"version-history":[{"count":1,"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=\/wp\/v2\/posts\/2088\/revisions"}],"predecessor-version":[{"id":2089,"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=\/wp\/v2\/posts\/2088\/revisions\/2089"}],"wp:attachment":[{"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=2088"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=2088"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.ronella.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=2088"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}