[CONF] Apache Camel: Error Handler (page edited)

Sat, 05 Jul 2008 06:43:05 -0700

Page Edited : CAMEL : Error Handler

Error Handler has been edited by Claus Ibsen (Jul 05, 2008).

Change summary:

CAMEL-670

(View changes)

Content:

Error Handler

Camel supports pluggable ErrorHandler strategies to deal with errors processing an Event Driven Consumer. An alternative is to specify the error handling directly in the DSL using the Exception Clause.

Some current implementations include

These error handlers can be applied in the DSL to an entire set of rules or a specific routing rule as we show in the next examples. Error handling rules are inherited on each routing rule within a single RouteBuilder

Setting global error handlers

The following example shows how you can register a global error handler (in this case using the logging handler)

RouteBuilder builder = new RouteBuilder() {
    public void configure() {
        errorHandler(loggingErrorHandler("FOO.BAR"));
        from("seda:a").to("seda:b");
    }
};


Setting error handlers on a specific route



The following example shows how you can register a local error handler; the customized logging handler is only registered for the route from Endpoint seda:a





RouteBuilder builder = new RouteBuilder() {
    public void configure() {
        from("seda:a").errorHandler(loggingErrorHandler("FOO.BAR")).to("seda:b");
        // this route will use the default error handler,
        // DeadLetterChannel
        from("seda:b").to("seda:c");
    }
};





Default Error Handler



The default error handler is the Dead Letter Channel which is automatically configured for you. You can then configure the specific dead letter endpoint to use either for an entire rule base or a specific rule as shown above. For example





RouteBuilder builder = new RouteBuilder() {
    public void configure() {
        errorHandler(deadLetterChannel("seda:errors"));
        from("seda:a").to("seda:b");
    }
};





Overriding default behavior



You can also configure the RedeliveryPolicy as this example shows





RouteBuilder builder = new RouteBuilder() {
    public void configure() {
        errorHandler(deadLetterChannel("seda:errors").maximumRedeliveries(2).useExponentialBackOff());
        from("seda:a").to("seda:b");
    }
};





As of Camel 1.4 you can configure the ExceptionPolicyStrategy as this example shows





public void configure() throws Exception {
    // configure the error handler to use my policy instead of the default from Camel
    errorHandler(deadLetterChannel().exceptionPolicyStrategy(new MyPolicy()));

    exception(MyPolicyException.class)
        .maximumRedeliveries(1)
        .setHeader(MESSAGE_INFO, "Damm my policy exception")
        .to(ERROR_QUEUE);

    exception(CamelException.class)
        .maximumRedeliveries(3)
        .setHeader(MESSAGE_INFO, "Damm a Camel exception")
        .to(ERROR_QUEUE);





Using our own strategy MyPolicy we can change the default behavior of Camel with our own code to resolve which ExceptionType from above should be handling the given thrown exception.





public static class MyPolicy implements ExceptionPolicyStrategy {

    public ExceptionType getExceptionPolicy(Map<Class, ExceptionType> exceptionPolicices,
                                            Exchange exchange,
                                            Throwable exception) {
        // This is just an example that always forces the exception type configured
        // with MyPolicyException to win.
        return exceptionPolicices.get(MyPolicyException.class);
    }
}





See also Dead Letter Channel for further details.

Powered by Atlassian Confluence (Version: 2.2.9 Build:#527 Sep 07, 2006) - Bug/feature request

Unsubscribe or edit your notifications preferences

Reply via email to