Polish java module test codes

Signed-off-by: Taeik Lim <[email protected]>

Author: acktsap

spring-batch-plus/src/integrationTest/java/com/navercorp/spring/batch/plus/item/adapter/ItemStreamReaderProcessorWriterIntegrationTest.java

@@ -18,9 +18,6 @@
 
 package com.navercorp.spring.batch.plus.item.adapter;
 
-import static com.navercorp.spring.batch.plus.item.adapter.AdapterFactory.itemProcessor;
-import static com.navercorp.spring.batch.plus.item.adapter.AdapterFactory.itemStreamReader;
-import static com.navercorp.spring.batch.plus.item.adapter.AdapterFactory.itemStreamWriter;
 import static org.assertj.core.api.Assertions.assertThat;
 
 import java.util.UUID;
@@ -56,7 +53,8 @@
 
 import reactor.core.publisher.Flux;
 
-@SuppressWarnings("unchecked")
+// note: it's deprecated. Do not change it.
+@SuppressWarnings({"unchecked", "deprecation"})
 class ItemStreamReaderProcessorWriterIntegrationTest {
 
 	private static final int TEST_REPEAT_COUNT = 5;
@@ -112,9 +110,9 @@ void testReaderProcessorWriter() throws Exception {
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.processor(itemProcessor(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.processor(AdapterFactory.itemProcessor(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();
@@ -157,9 +155,9 @@ void testReaderProcessorWriterWithSameTaskletShouldKeepContext() throws Exceptio
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.processor(itemProcessor(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.processor(AdapterFactory.itemProcessor(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();
@@ -198,9 +196,9 @@ void testStepScopeReaderProcessorWriter() throws Exception {
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.processor(itemProcessor(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.processor(AdapterFactory.itemProcessor(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();
@@ -243,9 +241,9 @@ void testStepScopeReaderProcessorWriterWithSameTaskletShouldNotKeepCountContext(
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.processor(itemProcessor(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.processor(AdapterFactory.itemProcessor(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();

spring-batch-plus/src/integrationTest/java/com/navercorp/spring/batch/plus/item/adapter/ItemStreamReaderWriterIntegrationTest.java

@@ -18,8 +18,6 @@
 
 package com.navercorp.spring.batch.plus.item.adapter;
 
-import static com.navercorp.spring.batch.plus.item.adapter.AdapterFactory.itemStreamReader;
-import static com.navercorp.spring.batch.plus.item.adapter.AdapterFactory.itemStreamWriter;
 import static org.assertj.core.api.Assertions.assertThat;
 
 import java.util.UUID;
@@ -55,7 +53,8 @@
 
 import reactor.core.publisher.Flux;
 
-@SuppressWarnings("unchecked")
+// note: it's deprecated. Do not change it.
+@SuppressWarnings({"unchecked", "deprecation"})
 class ItemStreamReaderWriterIntegrationTest {
 
 	private static final int TEST_REPEAT_COUNT = 5;
@@ -107,8 +106,8 @@ void testReaderWriter() throws Exception {
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();
@@ -151,8 +150,8 @@ void testReaderWriterWithSameTaskletShouldKeepCountContext() throws Exception {
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();
@@ -190,8 +189,8 @@ void testStepScopeReaderWriter() throws Exception {
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();
@@ -234,8 +233,8 @@ void testStepScopeReaderWriterWithSameTaskletShouldNotKeepCountContext() throws
 			.start(
 				new StepBuilder("testStep", jobRepository)
 					.<Integer, Integer>chunk(chunkCount, new ResourcelessTransactionManager())
-					.reader(itemStreamReader(testTasklet))
-					.writer(itemStreamWriter(testTasklet))
+					.reader(AdapterFactory.itemStreamReader(testTasklet))
+					.writer(AdapterFactory.itemStreamWriter(testTasklet))
 					.build()
 			)
 			.build();