我有两个活跃的连接:
1.连接A 2.连接B
我的 LoadBalancer 代码如下所示:
methodA() {
configureOnExceptions();
LoadBalanceDefinition loadBalanceDefinition =
from(uri)
.onCompletion().
.onCompleteOnly()
.process(successfulSubmissionProcessor)
.end()
.loadBalance()
.failover(1, true, true, true); // maximumFailoverAttempts, inheritErrorHandler, roundrobin, //sticky
for (connection name: connectionList) {
String route = build route using + connectionA or connectionB accordingly;
loadBalanceDefinition.to(route);
}
loadBalanceDefinition.end();
}
private void configureOnExceptions() {
onException(Throwable.class)
.handled(false)
.maximumRedeliveries(3)
.redeliveryDelay(3000)
.useOriginalMessage()
.process(exceptionHandlingProcessor)
.end();
}
期望:
实际:
问题: