Как совместить повторную попытку и автоматический выключатель в 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 Class

package com.camel.examples;

public class MyException extends Exception{

    public MyException() {
    super();

    }

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