Examples of org.apache.camel.model.config.BatchResequencerConfig

org.apache.camel.model.config.BatchResequencerConfig

Defines the configuration parameters for the batch-processing {@link Resequencer}. Usage example:

 from("direct:start").resequencer(body()).batch( BatchResequencerConfig.getDefault()).to("mock:result")

is equivalent to

 from("direct:start").resequencer(body()).batch().to("mock:result")

 from("direct:start").resequencer(body()).to("mock:result")

Custom values for batchSize and batchTimeout can be set like in this example:

 from("direct:start").resequencer(body()).batch( new BatchResequencerConfig(300, 400L)).to("mock:result")

@author Martin Krasser @version $Revision: 630568 $

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequence(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequencer(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequence(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequence(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequencer(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequence(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequencer(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

            public void configure() {


                from("activemq:queue:batch")
                    .to(callExecuteOnBean("myBean1"))
                    .resequence(header("seqnum"))
                    .batch(new BatchResequencerConfig(100, 2000L))
                    .to(callExecuteOnBean("myBean2"))
                    .to("activemq:queue:stop");
                
                from("activemq:queue:stream")
                    .to(callExecuteOnBean("myBean1"))

View Full Code Here

TOP

Related Classes of org.apache.camel.model.config.BatchResequencerConfig

org.apache.camel.itest.jms.JmsResequencerTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.