问Camel按长度而不是令牌拆分InputStream

EN

@Override
public void configure() throws Exception {
  from("file:src/data?delay=3000&noop=true")
      .split().tokenize("", 10).streaming()
      .aggregate().constant(true) // all messages have the same correlator
        .aggregationStrategy(new GroupedMessageAggregationStrategy())
        .completionSize(1000)
        .completionTimeout(5000) // use a timeout or a predicate 
                                 // to know when to stop
      .process(new Processor() { // process the aggregate
        @Override
        public void process(final Exchange e) throws Exception {
          final List<Message> aggregatedMessages = 
            (List<Message>) e.getIn().getBody();
          StringBuilder builder = new StringBuilder();
          for (Message message : aggregatedMessages) {
            builder.append(message.getBody()).append("-");
          }
          e.getIn().setBody(builder.toString());
        }
      })
      .log("Got ${body}")
      .delay(2000);
}

from("direct:body")
        // here we use a POJO bean mySplitterBean to do the split of the payload
        .split().method("mySplitterBean", "splitBody")

public class MySplitterBean {

    /**
     * The split body method returns something that is iteratable such as a java.util.List.
     *
     * @param body the payload of the incoming message
     * @return a list containing each part splitted
     */
    public List<String> splitBody(String body) {
        // since this is based on an unit test you can of cause
        // use different logic for splitting as Camel have out
        // of the box support for splitting a String based on comma
        // but this is for show and tell, since this is java code
        // you have the full power how you like to split your messages
        List<String> answer = new ArrayList<String>();
        String[] parts = body.split(",");
        for (String part : parts) {
            answer.add(part);
        }
        return answer;
    }