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

IN PROGRESS - issue BATCH-7: Remove transaction synchronization and state management from input/output sources (formerly buffering)

Browse Source 
http://jira.springframework.org/browse/BATCH-7

Check for isMarkSupported().
This commit is contained in:
dsyer
2008-02-02 15:19:49 +00:00
parent 2d1ccb0cc6
commit ee779e15f3
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/stream/SimpleStreamManager.java
View File

@@ -99,7 +99,7 @@ public class SimpleStreamManager implements StreamManager {
Properties properties = provider.getStreamContext().getProperties();
if (properties != null) {
String prefix = ""; // ClassUtils.getShortClassName(provider.getClass())
// + ".";
// + ".";
for (Iterator propiter = properties.keySet().iterator(); propiter.hasNext();) {
String key = (String) propiter.next();
String value = properties.getProperty(key);
@@ -155,14 +155,18 @@ public class SimpleStreamManager implements StreamManager {
if (status == TransactionSynchronization.STATUS_COMMITTED) {
iterate(key, new Callback() {
public void execute(ItemStream stream) {
stream.mark(stream.getStreamContext());
if (stream.isMarkSupported()) {
stream.mark(stream.getStreamContext());
}
}
});
}
else if (status == TransactionSynchronization.STATUS_ROLLED_BACK) {
iterate(key, new Callback() {
public void execute(ItemStream stream) {
stream.reset(stream.getStreamContext());
if (stream.isMarkSupported()) {
stream.reset(stream.getStreamContext());
}
}
});
}
@@ -208,5 +212,4 @@ public class SimpleStreamManager implements StreamManager {
void execute(ItemStream stream);
}
}