What do you return from your custom split method?

It should be an Iterator, to work well with the streaming mode.

Well if you return a List which then returns the parts on-the-fly.

If you use a custom Iterator to read the file piece by piece then that works well with the streaming mode of the Camel Splitter EIP.

This is similar to as how the Scanner works. If you just want to split your file by a special token etc then the Scanner is a great choice. And Camel DSL have syntax sugar for this using the tokenizer.

If you need something more advanced/custom, then just use a custom Iterator. For example you can read in X number of bytes at each iteration step.

Just return Iterator as the return type of the method.

Then implement the Iterator to read a chunk of the file piece by piece and return it in next() and the hasNext() method.

I am sure you can google and find some examples.

Read chapter 4 in the Camel book which talks about using beans with Camel.

public Iterator foo(File file) {
   return new Iterator() {
       // implement me to return chunks of the file
   };
}

Would you be able to provide the sample code on this example?

On the following page:  http://camel.apache.org/splitter.html ,  there is an excerpt that I have questions about.

++ Excerpt - Start ++

import static org.apache.camel.builder.ExpressionBuilder.beanExpression;

from("direct:streaming")

     .split(beanExpression(new MyCustomIteratorFactory(),  "iterator"))

     .streaming().to("activemq:my.parts")

++ Excerpt - End ++

Can someone provided me with same code for the MyCustomIteratorFactory class?

Basically I have one huge file, that I want to split into many jms messages.

The following is an outline of my current thoughts...

    public void configure() throws Exception

    {

        from( "file://file-item-list/general?initialDelay=1000&delay=5000&delete=true" )

            .transacted( "PROPAGATION_REQUIRED" )

            .split(ExpressionBuilder.beanExpression(new MyCustomFileChunkIterator(),  "iterator"))  // split big file of items into smaller chunks

            .streaming()

            .to("activemq:queue:file-item-sublist-request");

    }

Edited by: marks1900 on Dec 16, 2011 7:18 AM