Apache的駱駝：GroupedExchangeAggregationStrategy組DefaultExchange代替消息主體

Question

在繼續給其他線程， Apache Camel : File to BeanIO and merge beanIO objects based on id

試圖組使用GroupedExchangeAggregationStrategy的EmployeeDetails如下

from("seda:aggregate").aggregate(simple("${body.id}"), new 
MergeAggregationStrategy()).completionSize(3).log("Details - ${header.details}").to("seda:formList"); 

from("seda:formList").aggregate(new 
GroupedExchangeAggregationStrategy()).constant(true).completionTimeout(10) 
    .process(EmployeeDetailsBeanProcessor).log("Final list of groupedExchangeAggr ${body}") 
    .log("FILE PROCESSING COMPLETED"); 

EmployeeDetailsBeanProcessor：

public class EmployeeDetailsBeanProcessor implements Processor{ 
    public void process(Exchange exchange) throws Exception { 
     ArrayList<EmployeeDetails> rows = exchange.getIn().getBody(ArrayList.class); 
     for (EmployeeDetails record : rows)  { 
      System.out.println("----- Record:: ----- "+ 
       record.getId() + " "+ 
       record.getName() + " " + 
       record.getJob() +" "+ 
       record.getEmail() + " "+ 
       record.getCity()+" "+ 
       record.getCode()); 
     } 
    } 
} 

我的理解是當GroupExchangedAggregationStr使用ategy時，當前的Exchange將被添加到列表中，但是在測試時它會添加DefaultExchange而不是當前的Exchange和EmployeeDetails。

ERROR 4236 --- [eTimeoutChecker] o.a.camel.processor.DefaultErrorHandler : Failed delivery for (MessageId: ID-admin-PC-49678-1508604904882-0-30 on ExchangeId: ID-admin-PC-49678-1508604904882-0-29). Exhausted after delivery 
attempt: 1 caught: java.lang.ClassCastException: org.apache.camel.impl.DefaultExchange cannot be cast to com.test.EmployeeDetails 

你能給出一些關於分組交換的例子或說明嗎？提前致謝。

Answer 1

不，你在EmployeeDetailsBeanProcessor錯了。身體交換是列表而不是列表。

使用GroupedExchangeAggregationStrategy僅適用於特殊用途，並且可能使用了錯誤的策略。如果你想組合在一起作爲List<EmployeeDetails>那麼你可以使用FlexibleAggregationStrategy看這個單元測試的例子：https://github.com/apache/camel/blob/master/camel-core/src/test/java/org/apache/camel/util/toolbox/FlexibleAggregationStrategiesTest.java