BATCH-1100: moved state data update to @AfterWrite method

spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/internal/TradeWriter.java

@@ -22,12 +22,14 @@ import java.util.List;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.springframework.batch.core.annotation.AfterWrite;
 import org.springframework.batch.item.ExecutionContext;
 import org.springframework.batch.item.ItemStreamException;
 import org.springframework.batch.item.ItemStreamSupport;
 import org.springframework.batch.item.ItemWriter;
 import org.springframework.batch.sample.domain.trade.Trade;
 import org.springframework.batch.sample.domain.trade.TradeDao;
+import org.springframework.util.Assert;
 
 /**
  * Delegates the actual writing to custom DAO delegate. Allows configurable
@@ -47,23 +49,26 @@ public class TradeWriter extends ItemStreamSupport implements ItemWriter<Trade>
 
 	public void write(List<? extends Trade> trades) {
 
-		BigDecimal amount = BigDecimal.ZERO;
-
 		for (Trade trade : trades) {
 
 			log.debug(trade);
 
 			dao.writeTrade(trade);
 
-			amount = amount.add(trade.getPrice());
+			Assert.notNull(trade.getPrice()); // There must be a price to total
 
 			if (this.failingCustomers.contains(trade.getCustomer())) {
 				throw new RuntimeException("Something unexpected happened!");
 			}
 		}
 
-		this.totalPrice = this.totalPrice.add(amount);
+	}
 
+	@AfterWrite
+	public void updateTotalPrice(List<Trade> trades) {
+		for (Trade trade : trades) {
+			this.totalPrice = this.totalPrice.add(trade.getPrice());
+		}
 	}
 
 	@Override

spring-batch-samples/src/main/resources/jobs/skipSampleJob.xml

@@ -38,7 +38,8 @@
 
 		<listeners>
 			<listener ref="skipCheckingListener"/>
-			<listener ref="promotionListener"/>
+			<listener ref="promotionListener"/>
+			<listener ref="tradeWriter"/>
 		</listeners>
 	</step>
 	

spring-batch-samples/src/test/java/org/springframework/batch/sample/SkipSampleFunctionalTests.java

@@ -24,7 +24,6 @@ import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 import org.springframework.test.jdbc.SimpleJdbcTestUtils;
-import org.springframework.transaction.annotation.Transactional;
 
 /**
  * Error is encountered during writing - transaction is rolled back and the
@@ -126,7 +125,6 @@ public class SkipSampleFunctionalTests {
 	 * <li>This step does not occur. No error records are logged.
 	 * </ul>
 	 */
-	@Transactional
 	@Test
 	public void testJobIncrementing() {
 		//
@@ -136,10 +134,7 @@ public class SkipSampleFunctionalTests {
 		Map<String, Object> execution1 = this.getJobExecution(id1);
 		assertEquals("COMPLETED", execution1.get("STATUS"));
 
-		//
-		// TODO: Uncomment this!
-		//
-		// this.validateLaunchWithSkips();
+		this.validateLaunchWithSkips();
 
 		//
 		// Clear the data