From a3ba1913f2b889ce71d94b66b08501702d5fc1c9 Mon Sep 17 00:00:00 2001
From: trisberg <trisberg@2e8e966d-6415-0410-94b9-dc4e65435d03>
Date: Tue, 28 Oct 2008 20:00:07 +0000
Subject: [PATCH] modified property isReaderTransactional to be
 isReaderTransactionalQueue for clarity since it only applies to queue readers

---
 .../core/step/item/FaultTolerantStepFactoryBean.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantStepFactoryBean.java b/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantStepFactoryBean.java
index 3ec060b45..54e9074bb 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantStepFactoryBean.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantStepFactoryBean.java
@@ -71,10 +71,10 @@ public class FaultTolerantStepFactoryBean<T, S> extends SimpleStepFactoryBean<T,
 
 	private RetryContextCache retryContextCache;
 
-	private boolean isReaderTransactional = false;
+	private boolean isReaderTransactionalQueue = false;
 
-	public void setIsReaderTransactional(boolean isReaderTransactional) {
-		this.isReaderTransactional = isReaderTransactional;
+	public void setIsReaderTransactionalQueue(boolean isReaderTransactionalQueue) {
+		this.isReaderTransactionalQueue = isReaderTransactionalQueue;
 	}
 
 	/**
@@ -257,7 +257,7 @@ public class FaultTolerantStepFactoryBean<T, S> extends SimpleStepFactoryBean<T,
 			ItemSkipPolicy writeSkipPolicy = new LimitCheckingItemSkipPolicy(skipLimit, exceptions,
 					new ArrayList<Class<? extends Throwable>>(fatalExceptionClasses));
 
-			if (isReaderTransactional) {
+			if (isReaderTransactionalQueue) {
 				NonbufferingFaultTolerantChunkOrientedTasklet<T, S> tasklet = new NonbufferingFaultTolerantChunkOrientedTasklet<T, S>(
 						getItemReader(), getItemProcessor(), getItemWriter(), getChunkOperations(), retryTemplate,
 						rollbackClassifier, readSkipPolicy, writeSkipPolicy, writeSkipPolicy);