（Spring batch）带应答的可查询通道包含ChunkResponsessions，即使作业成功完成

Question

    <bean id="chunkWriter" class="org.springframework.batch.integration.chunk.ChunkMessageChannelItemWriter" scope="step">
    <property name="messagingOperations" ref="messagingGateway" />
    <property name="replyChannel" ref="masterChunkReplies" />
    <property name="throttleLimit" value="5" />
    <property name="maxWaitTimeouts" value="30000" />
</bean>

 <bean id="messagingGateway" class="org.springframework.integration.core.MessagingTemplate">
    <property name="defaultChannel" ref="masterChunkRequests" />
    <property name="receiveTimeout" value="2000" />
</bean>

<!-- Remote Chunking Replies From Slave -->
<jms:inbound-channel-adapter id="masterJMSReplies"
                             destination="remoteChunkingRepliesQueue"
                             connection-factory="remoteChunkingConnectionFactory"
                             channel="masterChunkReplies">
    <int:poller fixed-delay="10" />
</jms:inbound-channel-adapter>

<int:channel id="masterChunkReplies">
    <int:queue />
    <int:interceptors>
        <int:wire-tap channel="loggingChannel"/>
    </int:interceptors>
</int:channel>

Message contained wrong job instance id ["
                + jobInstanceId + "] should have been [" + localState.getJobId() + "]."

有一个简单的变通方法，在作业开始时清理MasterChunkReplelies队列通道，但我不确定它是否正确...

你能澄清一下吗？

Answer 1

加里，我找到根本原因了。

在从服务器上，如果我更改以下块使用者JMS适配器：

<jms:message-driven-channel-adapter id="slaveRequests"
                                    connection-factory="remoteChunkingConnectionFactory"
                                    destination="remoteChunkingRequestsQueue"
                                    channel="chunkRequests"
                                    concurrent-consumers="10"
                                    max-concurrent-consumers="50"
                                    acknowledge="transacted"
                                    receive-timeout="5000"
                                    idle-task-execution-limit="10"
                                    idle-consumer-limit="5"

        />

对于

<jms:inbound-channel-adapter id="jmsRequests" connection-factory="remoteChunkingConnectionFactory"
                             destination="remoteChunkingRequestsQueue"
                             channel="chunkRequests"
                             acknowledge="transacted"
                             receive-timeout="5000"
        >
    <int:poller fixed-delay="100"/>
</jms:inbound-channel-adapter>

Message contained wrong job instance id ["
            + jobInstanceId + "] should have been [" + localState.getJobId() + "]."