Issue

We received a NullPointerException using the aggregator if the initial message which has to be aggregated meets the criteria using a completionPredicate. In this case, completionSize equals to 1 and there is no correlationId.

2014-01-18 09:45:48,922 | DEBUG | ] | JdbcAggregationRepository        | 249 - org.apache.camel.camel-sql - 2.12.0.redhat-610139 | Getting key  [root.apvtOWYufeg2HWa773wPJw] -> null
2014-01-18 09:45:48,924 | WARN  | app.document] | DefaultIntegrationManager        | 282 - app.app-base-integration - 4.0.1.SNAPSHOT | 3APP200002: NullPointerException is a processing exception.
2014-01-18 09:45:48,925 | ERROR | app.document] | DefaultIntegrationManager        | 282 - app.app-base-integration - 4.0.1.SNAPSHOT | 2APP200004: A processing fault for message with retentionId 6a9bed39662e7de8361d66bbef7c0f27 and body com.mycompany.etc.emailservice.EmailAcknowledgeReceipt@1ca7204 has occurred in route app.document.callback.dispatcher with origin Endpoint[activemqTx://app.document?maxConcurrentConsumers=1] when calling CRM.
java.lang.NullPointerException
      at org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository$4.doInTransactionWithoutResult(JdbcAggregationRepository.java:300)
      at org.springframework.transaction.support.TransactionCallbackWithoutResult.doInTransaction(TransactionCallbackWithoutResult.java:33)
      at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:131)
      at org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository.remove(JdbcAggregationRepository.java:297)
      at org.apache.camel.processor.aggregate.AggregateProcessor.onCompletion(AggregateProcessor.java:459)
      at org.apache.camel.processor.aggregate.AggregateProcessor.doAggregation(AggregateProcessor.java:343)
      at org.apache.camel.processor.aggregate.AggregateProcessor.doProcess(AggregateProcessor.java:247)
      at org.apache.camel.processor.aggregate.AggregateProcessor.process(AggregateProcessor.java:179)
      at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)