apache-camel - 如何在 Apache Camel 中结合重试和断路器？

Question

我想重试 3 次，然后将失败阈值增加到 1。当这个阈值达到 5 时，我想在 Apache Camel 中打开电路。

我知道 Camel 支持断路器，但是我找不到可以将重试与它结合使用的示例。

任何帮助是极大的赞赏。

提前致谢。

拉梅什。

Answer 1

你可以试试下面的代码

<!--  Just Throws an exception of type MyException which is a custom Exception -->
<bean id="myBean" class="com.camel.examples.MyExceptionClass" />
<camel:errorHandler id="defaultErrorHandler" type="DefaultErrorHandler">
    <camel:redeliveryPolicy maximumRedeliveries="3"
        redeliveryDelay="1000" logStackTrace="false" />
</camel:errorHandler>
<camel:camelContext>
    <camel:route>
        <camel:from uri="timer:foo?repeatCount=8&amp;period=10000" />
        <camel:setBody>
            <camel:constant>Sundar</camel:constant>
        </camel:setBody>
        <camel:loadBalance>
            <camel:circuitBreaker threshold="5" halfOpenAfter="1000">
                <camel:exception>java.lang.Exception</camel:exception>
            </camel:circuitBreaker>
            <camel:to uri="direct:a" />
        </camel:loadBalance>
    </camel:route>
    <camel:route id="myroute" errorHandlerRef="defaultErrorHandler">
        <camel:from uri="direct:a" />
        <camel:process ref="myBean"></camel:process>
        <camel:log message="${exception}]" />
    </camel:route>
</camel:camelContext>

类 MyExceptionClass.java

package com.camel.examples;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyExceptionClass implements Processor{
    Logger Logger = LoggerFactory.getLogger(MyExceptionClass.class);
    @Override
    public void process(Exchange exchange) throws Exception {   
        throw new MyException("Other Exceptions");
    }
}

MyException 类

package com.camel.examples;

public class MyException extends Exception{

    public MyException() {
    super();

    }

    public MyException(String message){
        super("My Exception : "+message);
    }
}