Java Reference
In-Depth Information
...
<beans:bean id="chunkHandler"
class="org.springframework.batch.integration.chunk.RemoteChunkHandlerFactoryBean">
<beans:property name="chunkWriter" ref="chunkWriter" />
<beans:property name="step" ref="step1" />
</beans:bean>
<beans:bean id="chunkWriter"
class="org.springframework.batch.integration.chunk.ChunkMessageChannelItemWriter"
scope="step">
<beans:property name="messagingOperations" ref="messagingGateway" />
<beans:property name="replyChannel" ref="replies" />
<beans:property name="maxWaitTimeouts" value="10"/>
</beans:bean>
<beans:bean id="messagingGateway"
class="org.springframework.integration.core.MessagingTemplate">
<beans:property name="defaultChannel" ref="requests"/>
<beans:property name="receiveTimeout" value="1000"/>
</beans:bean>
<int:channel id="requests" />
<int:channel id="incoming" />
<int-jms:outbound-channel-adapter connection-factory="connectionFactory"
channel="requests" destination-name="requests" />
<int:transformer input-channel="incoming" output-channel="replies"
ref="headerExtractor" method="extract" />
<beans:bean id="headerExtractor"
class="org.springframework.batch.integration.chunk.JmsRedeliveredExtractor" />
<int:channel id="replies">
<int:queue />
<int:interceptors>
<beans:bean id="pollerInterceptor"
class="org.springframework.batch.integration.chunk.MessageSourcePollerInterceptor">
<beans:property name="messageSource">
<beans:bean class="org.springframework.integration.jms.JmsDestinationPollingSource">
<beans:constructor-arg>
<beans:bean class="org.springframework.jms.core.JmsTemplate">
<beans:property name="connectionFactory" ref="connectionFactory" />
<beans:property name="defaultDestinationName" value="replies" />
<beans:property name="receiveTimeout" value="1000" />
</beans:bean>
</beans:constructor-arg>
</beans:bean>
</beans:property>
<beans:property name="channel" ref="incoming" />
