1

チャンクでスキップ制限を定義すると、retrytemplate が作成されますFaultTolerantStepBuilder。実際、私はこれを使いたくありませんRetryTemplate

org.springframework.batch.core.configuration.xml.StepParserStepFactoryBean#isFaultTolerant

ItemWriter org.springframework.retry.support.RetryTemplate#handleRetryExhausted私の ItemWriter の呼び出しに失敗した場合、この 2 番目の呼び出しをブロックする解決策はありません。再試行ポリシーを設定しても、この呼び出しには影響しません。

手伝っていただけませんか?この再試行をブロックする正しい方法が見つかりません。

<batch:job id="order">
    <batch:step id="orderStep1">
        <batch:tasklet>
            <batch:chunk reader="orderItemReaderAdapter" writer="orderItemWriter"
                         commit-interval="1" skip-limit="20" >
                <batch:skippable-exception-classes >
                    <batch:include class="java.lang.Exception"/>
                </batch:skippable-exception-classes>
            </batch:chunk>
            <batch:listeners>
                <batch:listener ref="orderBatchListener"/> 
            </batch:listeners>
        </batch:tasklet>
    </batch:step>
</batch:job>

<bean id="orderItemWriter" class="com.tr.xxx.xx.batch.write.OrderItemWriter" >
    <property name="sessionFactory" ref="sessionFactory"/>
</bean>

public class OrderItemWriter extends HibernateItemWriter<OrderTable>{
private static final Logger LOG = LoggerFactory.getLogger(OrderItemWriter.class);

@Autowired
private OrderServiceClient orderServiceClient;
@Autowired
private SessionFactory sessionFactory;

@Override
public void write(List<? extends OrderTable> items) {
    OrderTable order = items.get(0);
    LOG.info("order will be submitted  {}", order.getId());
    OrderRequest orderRequest = OrderRequest.creatBLOrderRequest(order);
    orderServiceClient.order(orderRequest);
    order.setModifiedBy("batch");
    super.write(items);
    LOG.info("submitted order is marked");
}

}

4

0 に答える 0