From 3385a19cb4ebc518652a1aa05d0cd306487feb47 Mon Sep 17 00:00:00 2001 From: Taeik Lim Date: Fri, 18 Nov 2022 04:41:23 +0900 Subject: [PATCH] Change StepBuilderHelper#enhance parameter type to AbstractStep Issue #4220 --- .../builder/AbstractTaskletStepBuilder.java | 6 +-- .../core/step/builder/StepBuilderHelper.java | 50 ++++++++----------- 2 files changed, 25 insertions(+), 31 deletions(-) diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/AbstractTaskletStepBuilder.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/AbstractTaskletStepBuilder.java index fb18a1f76..898e63ffe 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/AbstractTaskletStepBuilder.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/step/builder/AbstractTaskletStepBuilder.java @@ -21,12 +21,12 @@ import java.util.LinkedHashSet; import java.util.Set; import org.springframework.batch.core.ChunkListener; -import org.springframework.batch.core.Step; import org.springframework.batch.core.StepExecutionListener; import org.springframework.batch.core.annotation.AfterChunk; import org.springframework.batch.core.annotation.AfterChunkError; import org.springframework.batch.core.annotation.BeforeChunk; import org.springframework.batch.core.listener.StepListenerFactoryBean; +import org.springframework.batch.core.step.AbstractStep; import org.springframework.batch.core.step.tasklet.Tasklet; import org.springframework.batch.core.step.tasklet.TaskletStep; import org.springframework.batch.item.ItemStream; @@ -78,8 +78,8 @@ public abstract class AbstractTaskletStepBuilder> { return properties.allowStartIfComplete != null ? properties.allowStartIfComplete : false; } - protected void enhance(Step target) { - - if (target instanceof AbstractStep) { - - AbstractStep step = (AbstractStep) target; - step.setJobRepository(properties.getJobRepository()); - - ObservationRegistry observationRegistry = properties.getObservationRegistry(); - if (observationRegistry != null) { - step.setObservationRegistry(observationRegistry); - } - - MeterRegistry meterRegistry = properties.getMeterRegistry(); - if (meterRegistry != null) { - step.setMeterRegistry(meterRegistry); - } - - Boolean allowStartIfComplete = properties.allowStartIfComplete; - if (allowStartIfComplete != null) { - step.setAllowStartIfComplete(allowStartIfComplete); - } - - step.setStartLimit(properties.startLimit); - - List listeners = properties.stepExecutionListeners; - if (!listeners.isEmpty()) { - step.setStepExecutionListeners(listeners.toArray(new StepExecutionListener[0])); - } + protected void enhance(AbstractStep step) { + step.setJobRepository(properties.getJobRepository()); + ObservationRegistry observationRegistry = properties.getObservationRegistry(); + if (observationRegistry != null) { + step.setObservationRegistry(observationRegistry); } + MeterRegistry meterRegistry = properties.getMeterRegistry(); + if (meterRegistry != null) { + step.setMeterRegistry(meterRegistry); + } + + Boolean allowStartIfComplete = properties.allowStartIfComplete; + if (allowStartIfComplete != null) { + step.setAllowStartIfComplete(allowStartIfComplete); + } + + step.setStartLimit(properties.startLimit); + + List listeners = properties.stepExecutionListeners; + if (!listeners.isEmpty()) { + step.setStepExecutionListeners(listeners.toArray(new StepExecutionListener[0])); + } } public static class CommonStepProperties {