camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Miguel Ruiz Velasco Sobrino <miguel...@fcm.com.mx>
Subject Question about loadbalancing failover
Date Tue, 17 Jul 2012 00:17:29 GMT
Hello,

I'm fairly new to camel, and I have a problem.
I already have a camel configuration with loadbalancing and failover, 
and it works wonders when at least one of the processors succeeds.
I have an scenario maybe all processors fail, and camel loops infinitely 
doing the failover.
I need to know when all failover attempts failed to send an error 
message to the service's clients, because I don't want it to rollback 
and to loop forever.
I think I may need to catch somewhere an exception... but which exception?

My [simplified] test config is as follows:

<camel:camelContext id="camelContext" >
<camel:errorHandler id="miguelErrorHandler"
                 type="DefaultErrorHandler"
                 redeliveryPolicyRef="generalRedeliveryPolicy"
                 useOriginalMessage="false"
 >

</camel:errorHandler>

<camel:redeliveryPolicyProfile id="generalRedeliveryPolicy" 
redeliveryDelay="200" maximumRedeliveries="1" />
<camel:redeliveryPolicyProfile id="redeliveryPolicy" 
redeliveryDelay="500" maximumRedeliveries="1"/>

<camel:route errorHandlerRef="miguelErrorHandler">
<camel:from uri="file:data/inbox" />

<camel:onException redeliveryPolicyRef="redeliveryPolicy" >
<camel:exception>java.lang.NoSuchMethodException</camel:exception>
<camel:handled><camel:constant>true</camel:constant></camel:handled>
<camel:to uri="seda:err"/>
</camel:onException>

<camel:loadBalance inheritErrorHandler="true" >
<camel:failover maximumFailoverAttempts="2" roundRobin="true"/>
<camel:process ref="failProcessor1"></camel:process>
<camel:process ref="failProcessor2"></camel:process>
</camel:loadBalance>

<camel:wireTap uri="stream:out" processorRef="downloadLogger"/> <!-- 
processorRef="downloadLogger" -->
<camel:to   uri="file:data/output" />
</camel:route>

</camel:camelContext>
<bean id="failProcessor1"  class="com.fcm.camel.test.FailProcessor"/>


The class FailProcessor only returns an exception to force the failover.

The log is as follows:

2012-07-16 19:05:15,505 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - Failover 
starting with endpoint index 0
2012-07-16 19:05:15,507 [Camel (camelContext) thread #1 - 
file://data/inbox] DEBUG 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
Processing failover at attempt 0 for Exchange[null]
2012-07-16 19:05:20,383 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR com.fcm.camel.test.FailedConnectProcessor  - 
failedConnectProcessor Falla intencional al conectar: Mensaje 1

2012-07-16 19:05:20,593 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR com.fcm.camel.test.FailedConnectProcessor  - 
failedConnectProcessor Falla intencional al conectar: Mensaje 1

2012-07-16 19:05:20,595 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR org.apache.camel.processor.DefaultErrorHandler  
- Failed delivery for (MessageId: ID-miguel-thnk-58270-1342483504051-0-4 
on ExchangeId: ID-miguel-thnk-58270-1342483504051-0-2). Exhausted after 
delivery attempt: 2 caught: java.net.ConnectException: Falla intencional 
al conectar Ex: failedConnectProcessor
java.net.ConnectException: Falla intencional al conectar Ex: 
failedConnectProcessor
     at 
com.fcm.camel.test.FailedConnectProcessor.process(FailedConnectProcessor.java:26)
     at 
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer.processExchange(FailOverLoadBalancer.java:247)
     at 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer.process(FailOverLoadBalancer.java:205)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)
     at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)
     at 
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)
     at 
org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:336)
     at 
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:189)
     at 
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:155)
     at 
org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:139)
     at 
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:91)
     at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
     at java.util.concurrent.FutureTask$Sync.innerRunAndReset(Unknown 
Source)
     at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Unknown 
Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Unknown 
Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown 
Source)
     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown 
Source)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
     at java.lang.Thread.run(Unknown Source)
2012-07-16 19:05:20,596 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
Processing exchangeId: ID-miguel-thnk-58270-1342483504051-0-2 is 
continued being processed synchronously
2012-07-16 19:05:20,596 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - Should 
failover: true for exchangeId: ID-miguel-thnk-58270-1342483504051-0-2
2012-07-16 19:05:20,597 [Camel (camelContext) thread #1 - 
file://data/inbox] DEBUG 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
Processing failover at attempt 1 for Exchange[null]
2012-07-16 19:05:20,597 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR com.fcm.camel.test.FailedConnectProcessor  - 
failedConnectProcessor Falla intencional al conectar: Mensaje 1

2012-07-16 19:05:20,799 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR com.fcm.camel.test.FailedConnectProcessor  - 
failedConnectProcessor Falla intencional al conectar: Mensaje 1

2012-07-16 19:05:20,800 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR org.apache.camel.processor.DefaultErrorHandler  
- Failed delivery for (MessageId: ID-miguel-thnk-58270-1342483504051-0-6 
on ExchangeId: ID-miguel-thnk-58270-1342483504051-0-2). Exhausted after 
delivery attempt: 2 caught: java.net.ConnectException: Falla intencional 
al conectar Ex: failedConnectProcessor
java.net.ConnectException: Falla intencional al conectar Ex: 
failedConnectProcessor
     at 
com.fcm.camel.test.FailedConnectProcessor.process(FailedConnectProcessor.java:26)
     at 
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer.processExchange(FailOverLoadBalancer.java:247)
     at 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer.process(FailOverLoadBalancer.java:205)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)
     at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)
     at 
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)
     at 
org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:336)
     at 
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:189)
     at 
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:155)
     at 
org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:139)
     at 
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:91)
     at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
     at java.util.concurrent.FutureTask$Sync.innerRunAndReset(Unknown 
Source)
     at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Unknown 
Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Unknown 
Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown 
Source)
     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown 
Source)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
     at java.lang.Thread.run(Unknown Source)
2012-07-16 19:05:20,802 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
Processing exchangeId: ID-miguel-thnk-58270-1342483504051-0-2 is 
continued being processed synchronously
2012-07-16 19:05:20,802 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - Should 
failover: true for exchangeId: ID-miguel-thnk-58270-1342483504051-0-2
2012-07-16 19:05:20,802 [Camel (camelContext) thread #1 - 
file://data/inbox] DEBUG 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
Processing failover at attempt 2 for Exchange[null]
2012-07-16 19:05:20,804 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR com.fcm.camel.test.FailProcessor  - 
failProcessor1 falla: Mensaje 1

2012-07-16 19:05:21,013 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR com.fcm.camel.test.FailProcessor  - 
failProcessor1 falla: Mensaje 1

2012-07-16 19:05:21,015 [Camel (camelContext) thread #1 - 
file://data/inbox] ERROR org.apache.camel.processor.DefaultErrorHandler  
- Failed delivery for (MessageId: ID-miguel-thnk-58270-1342483504051-0-8 
on ExchangeId: ID-miguel-thnk-58270-1342483504051-0-2). Exhausted after 
delivery attempt: 2 caught: java.lang.NoSuchMethodException: Falla 
intencional failProcessor1
java.lang.NoSuchMethodException: Falla intencional failProcessor1
     at com.fcm.camel.test.FailProcessor.process(FailProcessor.java:24)
     at 
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer.processExchange(FailOverLoadBalancer.java:247)
     at 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer.process(FailOverLoadBalancer.java:205)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)
     at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)
     at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
     at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)
     at 
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)
     at 
org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)
     at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)
     at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)
     at 
org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:336)
     at 
org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:189)
     at 
org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:155)
     at 
org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:139)
     at 
org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:91)
     at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
     at java.util.concurrent.FutureTask$Sync.innerRunAndReset(Unknown 
Source)
     at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Unknown 
Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Unknown 
Source)
     at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown 
Source)
     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown 
Source)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
     at java.lang.Thread.run(Unknown Source)
2012-07-16 19:05:21,016 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
Processing exchangeId: ID-miguel-thnk-58270-1342483504051-0-2 is 
continued being processed synchronously
2012-07-16 19:05:21,016 [Camel (camelContext) thread #1 - 
file://data/inbox] TRACE 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - Should 
failover: true for exchangeId: ID-miguel-thnk-58270-1342483504051-0-2
2012-07-16 19:05:21,016 [Camel (camelContext) thread #1 - 
file://data/inbox] DEBUG 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
*Breaking out of failover after 3 failover attempts*
2012-07-16 19:05:33,362 [Camel (camelContext) thread #1 - 
file://data/inbox] DEBUG 
org.apache.camel.processor.loadbalancer.FailOverLoadBalancer  - 
*Failover complete for exchangeId*: 
ID-miguel-thnk-58270-1342483504051-0-2 >>> Exchange[null]
2012-07-16 19:05:57,457 [Camel (camelContext) thread #1 - 
file://data/inbox] WARN 
*org.apache.camel.component.file.GenericFileOnCompletion  - Rollback 
file strategy: 
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy*@43036651 
for file: GenericFile[content]


Thanks

-- 
Miguel Ruiz Velasco Sobrino
FCM Computacion Mexicana SAPI de CV


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message