diff --git a/infrastructure/src/main/java/org/springframework/batch/item/provider/InputSourceItemProvider.java b/infrastructure/src/main/java/org/springframework/batch/item/provider/InputSourceItemProvider.java index 502cdc25f..a06bc0dd6 100644 --- a/infrastructure/src/main/java/org/springframework/batch/item/provider/InputSourceItemProvider.java +++ b/infrastructure/src/main/java/org/springframework/batch/item/provider/InputSourceItemProvider.java @@ -45,8 +45,7 @@ public class InputSourceItemProvider extends AbstractItemProvider implements Res * @see org.springframework.batch.item.ItemProvider#next() */ public Object next() { - Object value = inputSource.read(); - return value; + return inputSource.read(); } /** diff --git a/infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java b/infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java index 9d56e0fcb..cff2f2c57 100644 --- a/infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java +++ b/infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java @@ -57,6 +57,10 @@ public abstract class AbstractTradeBatchTests extends TestCase { inputSource.afterPropertiesSet(); setInputSource(inputSource); } + + public synchronized Object next() { + return super.next(); + } } protected static class TradeMapper implements FieldSetMapper{