チャンクでスキップ制限を定義すると、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");
}
}