Spring Batch DB未更新

Question

我在Tasklet中编写了一个业务逻辑，在该逻辑中，我向外部Systema的队列之一发送一条消息，然后使用operator.stop（）方法停止作业（有时响应来得很晚，所以我通过停止spring批处理作业来释放系统资源）。

一旦收到来自systemA的回复，我需要再次从上次完成的作业重新启动作业。

这就是我在tasklet中所做的。

public RepeatStatus execute(StepContribution stepCon, ChunkContext chunkCtx)
            throws Exception {

        JobOperator operator= (JobOperator)ApplicationContextProvider.getApplicationContext().getBean("jobOperator");

            String msg = "some msg";
    //Sending message to channel created using spring integration.
    messageChannel.send(MessageBuilder.withPayload(msg).build());
        //Stopping job with the job_exe_id 123
            operator.stop(123);
            ExitStatus es = new ExitStatus("MSG_SENT");
            stepCon.setExitStatus(es);
            return null;

    }

我现在面临的问题是，当消息被发送到systemA队列时，我立即得到systemA的响应，spring Integration的服务激活器被调用，由于某种原因，spring batch DB从未更新为“Stopped”，相反，DB条目将作业的状态显示为“Stopping”，因此我无法在服务激活器中重新启动作业，因为它仍然处于“Stopping”状态。

谁能让我知道为什么spring batch DB没有得到“Stopped”状态的更新。

编辑--我尝试在将消息发送到Systema队列之前停止作业，但SPRING BATCH DB仍然没有更新为“Stopeed”状态。

Answer 1

当我从外部系统获得响应时，我发送消息的tasklet事务没有提交。

为了解决上述问题，我使用了一个步骤执行监听器，我在tasklet中完成了所有的数据库更新，并在“afterstep”执行监听器中将消息发送到外部客户机，因此当流到达“afterstep”执行监听器时，tasklet事务已经提交。

希望这能帮助有需要的人。