318.6.3. CamelItemProcessor
CamelItemProcessor
是 Spring Batch org.springframework.batch.item.ItemProcessor
接口的实现。后者的实施转发是 请求 Reply 模式,以将批处理项目处理委派给 Camel 基础架构。要处理的项目作为消息正文发送到 Camel 端点。
例如,下面的代码片段使用直接 端点和简单表达式语言 执行简单的批处理。
<camel:camelContext> <camel:route> <camel:from uri="direct:processor"/> <camel:setExchangePattern pattern="InOut"/> <camel:setBody> <camel:simple>Processed ${body}</camel:simple> </camel:setBody> </camel:route> </camel:camelContext> <bean id="camelProcessor" class="org.apache.camel.component.spring.batch.support.CamelItemProcessor"> <constructor-arg ref="producerTemplate"/> <constructor-arg value="direct:processor"/> </bean> <batch:job id="myJob"> <batch:step id="step"> <batch:tasklet> <batch:chunk reader="someReader" writer="someWriter" processor="camelProcessor" commit-interval="100"/> </batch:tasklet> </batch:step> </batch:job>