RemoteChunkingManagerStepBuilderFactory 和 RemoteChunkingWorkerBuilder 的使用

问题描述

有没有人尝试过使用从 Spring 4.1 引入的远程分块类?根据 spring 文档,它消除了对 master 和 ChunkProcessor 的显式使用的 channelItemWriter 为 slave 配置。我有一个 XML 定义的 master 配置,其中使用 spring 批处理配置了多个步骤的作业。此外,faultTolerantChunkProcessor 被定义为从属块处理程序的块处理器。

但是,我的消息没有被推送到 ibm mq。我已经使用 java dsl 编写了相应的 spring 4.1 类。有人可以建议我一个好的方法吗?

解决方法

您可以在此处找到使用这些 API 的完整示例:https://github.com/spring-projects/spring-batch/tree/master/spring-batch-samples/src/main/java/org/springframework/batch/sample/remotechunking

示例可以通过以下测试执行:https://github.com/spring-projects/spring-batch/blob/master/spring-batch-samples/src/test/java/org/springframework/batch/sample/RemoteChunkingJobFunctionalTests.java 正在通过。该示例使用嵌入式 ActiveMQ 代理,但应与任何其他代理一起使用。