Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Re-order assertion to catch the problem if it exists earlier

Browse Source
This commit is contained in:
dsyer
2008-02-05 10:28:18 +00:00
parent 8ac9c65b78
commit 39210aa3d6
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-batch-samples/src/main/java/org/springframework/batch/sample/item/reader/StagingItemReader.java
View File

@@ -144,12 +144,12 @@ public class StagingItemReader extends JdbcDaoSupport implements ItemStream, Key
if (key == null) {
synchronized (lock) {
if (keys.hasNext()) {
Assert.state(TransactionSynchronizationManager.isActualTransactionActive(),
"Transaction not active for this thread.");
Long next = (Long) keys.next();
getBuffer().add(next);
key = next;
logger.debug("Retrieved key from list: " + key);
Assert.state(TransactionSynchronizationManager.isActualTransactionActive(),
"Transaction not active for this thread.");
}
}
}
@@ -218,7 +218,7 @@ public class StagingItemReader extends JdbcDaoSupport implements ItemStream, Key
/* (non-Javadoc)
* @see org.springframework.batch.item.ItemStream#mark(org.springframework.batch.item.ExecutionAttributes)
*/
public void mark(ExecutionAttributes executionAttributes) {
public void mark() {
getBuffer().commit();
}