Skip to content

Commit 63c8440

Browse files
committed
Polish BatchRegistrar
1. Remove unnecessary null check 2. Refine usage of `@SuppressWarnings("removal")` Signed-off-by: Yanming Zhou <[email protected]>
1 parent 088487b commit 63c8440

File tree

1 file changed

+6
-13
lines changed
  • spring-batch-core/src/main/java/org/springframework/batch/core/configuration/annotation

1 file changed

+6
-13
lines changed

spring-batch-core/src/main/java/org/springframework/batch/core/configuration/annotation/BatchRegistrar.java

Lines changed: 6 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
* @since 5.0
4646
* @see EnableBatchProcessing
4747
*/
48+
@SuppressWarnings("removal")
4849
class BatchRegistrar implements ImportBeanDefinitionRegistrar {
4950

5051
private static final Log LOGGER = LogFactory.getLog(BatchRegistrar.class);
@@ -128,14 +129,10 @@ private void registerJdbcJobRepository(BeanDefinitionRegistry registry, Annotati
128129
}
129130

130131
String charset = jdbcJobRepositoryAnnotation.charset();
131-
if (charset != null) {
132-
beanDefinitionBuilder.addPropertyValue("charset", Charset.forName(charset));
133-
}
132+
beanDefinitionBuilder.addPropertyValue("charset", Charset.forName(charset));
134133

135134
String tablePrefix = jdbcJobRepositoryAnnotation.tablePrefix();
136-
if (tablePrefix != null) {
137-
beanDefinitionBuilder.addPropertyValue("tablePrefix", tablePrefix);
138-
}
135+
beanDefinitionBuilder.addPropertyValue("tablePrefix", tablePrefix);
139136

140137
String databaseType = jdbcJobRepositoryAnnotation.databaseType();
141138
if (StringUtils.hasText(databaseType)) {
@@ -153,9 +150,7 @@ private void registerJdbcJobRepository(BeanDefinitionRegistry registry, Annotati
153150
jdbcJobRepositoryAnnotation.validateTransactionState());
154151

155152
Isolation isolationLevelForCreate = jdbcJobRepositoryAnnotation.isolationLevelForCreate();
156-
if (isolationLevelForCreate != null) {
157-
beanDefinitionBuilder.addPropertyValue("isolationLevelForCreateEnum", isolationLevelForCreate);
158-
}
153+
beanDefinitionBuilder.addPropertyValue("isolationLevelForCreateEnum", isolationLevelForCreate);
159154

160155
String jobKeyGeneratorRef = jdbcJobRepositoryAnnotation.jobKeyGeneratorRef();
161156
if (registry.containsBeanDefinition(jobKeyGeneratorRef)) {
@@ -181,9 +176,7 @@ private void registerMongoJobRepository(BeanDefinitionRegistry registry,
181176
beanDefinitionBuilder.addPropertyReference("transactionManager", transactionManagerRef);
182177
}
183178
Isolation isolationLevelForCreate = mongoJobRepositoryAnnotation.isolationLevelForCreate();
184-
if (isolationLevelForCreate != null) {
185-
beanDefinitionBuilder.addPropertyValue("isolationLevelForCreate", isolationLevelForCreate);
186-
}
179+
beanDefinitionBuilder.addPropertyValue("isolationLevelForCreate", isolationLevelForCreate);
187180

188181
String jobKeyGeneratorRef = mongoJobRepositoryAnnotation.jobKeyGeneratorRef();
189182
if (registry.containsBeanDefinition(jobKeyGeneratorRef)) {
@@ -248,7 +241,7 @@ private void registerJobOperator(BeanDefinitionRegistry registry, EnableBatchPro
248241
if (registry.containsBeanDefinition(taskExecutorRef)) {
249242
beanDefinitionBuilder.addPropertyReference("taskExecutor", taskExecutorRef);
250243
}
251-
@SuppressWarnings("removal")
244+
252245
String jobParametersConverterRef = batchAnnotation.jobParametersConverterRef();
253246
if (registry.containsBeanDefinition(jobParametersConverterRef)) {
254247
beanDefinitionBuilder.addPropertyReference("jobParametersConverter", jobParametersConverterRef);

0 commit comments

Comments
 (0)