5 Replies Latest reply on Sep 14, 2010 6:26 AM by davsclaus

    HawtDBAggregationRepository - Error getting key

    dekk11

      I have configured the aggregator to use a hawtdb aggregation repository.  When I attempt to aggregate files I get a RuntimeException from HawtDBAggregationRepository.  It appears to be returning a null Exchange from hawtdb, even though it appears to retrieve the exchange by key value.  Which property is it performing the lookup on with the correlationId value?

       

      Below is part of the stack trace.  Attached is the log with full stack trace:

      Failed delivery for exchangeId: 4007d562-6baa-4067-a4d6-c6b9547d5763. Exhausted after delivery attempt: 1 caught: java.lang.RuntimeException: Error getting key 4007d562-6baa-4067-a4d6-c6b9547d5763 from repository hawtdbFileRepo

      java.lang.RuntimeException: Error getting key 4007d562-6baa-4067-a4d6-c6b9547d5763 from repository hawtdbFileRepo

           at org.apache.camel.component.hawtdb.HawtDBAggregationRepository.get(HawtDBAggregationRepository.java:162)

           at org.apache.camel.processor.aggregate.AggregateProcessor.doAggregation(AggregateProcessor.java:203)

           at org.apache.camel.processor.aggregate.AggregateProcessor.process(AggregateProcessor.java:180)

           at org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)

      ....

       

      Below is the aggregator portion of the camel-context: