Apache Camel Iteration über Liste

Hier ist ein vollständiges Beispiel teilt aggregiert und konvertiert eine Liste Nachricht.

1. Der camel-splitter bietet einen integrierten aggregator die Aggregate
   allen geteilten Nachrichten in der ursprünglichen exchange. Also der splitter ist nur
   die Aggregation der Nachrichten der jeweiligen Liste(exchange) senden im "direct:start". Sie haben, um einen benutzerdefinierten
   aggregation-Strategie, weil das standardmäßig die ursprünglichen
   Austausch, in meinem Beispiel InOrder. Die aggregation-Strategie ist die
   zweites argument der split-definition.

2. Art Konverter gibt uns die Möglichkeit, in convertBodyTo
   DSL. Sie kann auch erreichen, dass Sie mit einer bean,Prozessor oder alles tun, die Transformationen in die benutzerdefinierte aggregation-Strategie.

   package org.mydemocamel.app;
   import org.apache.camel.*;
   import org.apache.camel.builder.RouteBuilder;
   import org.apache.camel.component.mock.MockEndpoint;
   import org.apache.camel.processor.aggregate.AggregationStrategy;
   import org.apache.camel.processor.aggregate.GroupedExchangeAggregationStrategy;
   import org.apache.camel.processor.aggregate.UseLatestAggregationStrategy;
   import org.apache.camel.processor.aggregate.UseOriginalAggregationStrategy;
   import org.apache.camel.support.TypeConverterSupport;
   import org.apache.camel.test.junit4.CamelTestSupport;
   import org.apache.camel.util.toolbox.FlexibleAggregationStrategy;
   import org.junit.Test;
   
   import java.util.ArrayList;
   import java.util.List;
   
   
   public class CamelSplitAggregateConvertTest extends CamelTestSupport {
   
       @Produce
       private ProducerTemplate template;
   
       @EndpointInject(uri = "mock:out")
       private MockEndpoint mock;
   
       @Test
       public void testSplitAggregateConvertOrder(){
           InOrder inOrder1 = new InOrder();
           inOrder1.setId("1");
   
           InOrder inOrder2 = new InOrder();
           inOrder2.setId("2");
   
           List<InOrder> inOrderList = new ArrayList<InOrder>();
           inOrderList.add(inOrder1);
           inOrderList.add(inOrder2);
   
           template.sendBody("direct:start", inOrderList);
   
           mock.expectedMessageCount(1);
           Exchange outList = mock.getReceivedExchanges().get(0);
           List<OutOrder> outOrderList = outList.getIn().getBody(List.class);
   
           assertEquals(1, outOrderList.get(0).getId());
           assertEquals(2, outOrderList.get(1).getId());
   
   
       }
   
       @Override
       protected RouteBuilder createRouteBuilder() throws Exception {
           return new RouteBuilder() {
               @Override
               public void configure() throws Exception {
   
                   context.getTypeConverterRegistry().addTypeConverter(OutOrder.class, InOrder.class, new MyOrderTypeConverter());
   
                   from("direct:start")
                   .split(body(), new AggregationStrategy() {
                       @Override
                       public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
                           if (oldExchange == null) {
                               List<OutOrder> orders = new ArrayList<OutOrder>();
                               OutOrder newOrder = newExchange.getIn().getBody(OutOrder.class);
                               orders.add(newOrder);
                               newExchange.getIn().setBody(orders);
                               return newExchange;
                           }
                           List<OutOrder> orders = oldExchange.getIn().getBody(List.class);
                           OutOrder newOutOrder = newExchange.getIn().getBody(OutOrder.class);
                           orders.add(newOutOrder);
                           oldExchange.getIn().setBody(orders);
                           return oldExchange;
                       }
                   })
                   .convertBodyTo(OutOrder.class)
                   .end()  //splitter ends here and the exchange body  is now List<OutOrder> 
                   .to("mock:out");
   
               }
           };
       }
   
       private static class MyOrderTypeConverter extends TypeConverterSupport {
   
           @SuppressWarnings("unchecked")
           public <T> T convertTo(Class<T> type, Exchange exchange, Object value) {
               //converter from inorder to outorder bean
               OutOrder order = new OutOrder();
               order.setId(Integer.parseInt(((InOrder) value).getId()));
               return (T) order;
           }
       }
   
       private static class OutOrder {
           private int id;
   
           public void setId(int id) {
               this.id = id;
           }
   
           public int getId() {
               return id;
           }
       }
   
       private static class InOrder {
           private String id;
   
           public void setId(String id) {
               this.id = id;
           }
   
           public String getId() {
               return id;
           }
       }
   }

Für die Zukunft, eine weitere Möglichkeit zum iterieren über eine Liste mit den loop konstruieren der Java-DSL. Hier ist ein Beispiel:

from("direct:myDirect")
.loop(header("LIST_LENGTH")) //You will set this header in the processor before with the list lenght.
.process(new Processor(){

      @Override
      public void proocess(Exchange arg0){
          MyObj currentElement = (MyObj) arg0.getIn().getBody(List.class).get(LOOP_INDEX);
          //Do your processing here.
      }
})
.end()
.end();

Den LOOP_INDEX - Eigenschaft enthält die aktuelle iteration, beginnend bei 0 bis zu der LIST_LENGHT header-Wert, so können Sie es verwenden, um das aktuelle element aus der Liste.

Beachten Sie die Doppel - end() Methode nennen: die eine ist für das Ende der Schleife und das andere Ende der route.

Dokumentation: http://camel.apache.org/loop.html