RESOLVED - issue BATCH-1419: Change is-reader-transactional-queue to reader-transactional in <chunk/>
http://jira.springframework.org/browse/BATCH-1419
This commit is contained in:
@@ -113,7 +113,7 @@ public class ChunkElementParser {
|
||||
propertyValues.addPropertyValue("cacheCapacity", cacheCapacity);
|
||||
}
|
||||
|
||||
String isReaderTransactionalQueue = element.getAttribute("is-reader-transactional-queue");
|
||||
String isReaderTransactionalQueue = element.getAttribute("reader-transactional-queue");
|
||||
if (StringUtils.hasText(isReaderTransactionalQueue)) {
|
||||
propertyValues.addPropertyValue("isReaderTransactionalQueue", isReaderTransactionalQueue);
|
||||
}
|
||||
|
||||
@@ -601,7 +601,7 @@
|
||||
]]></xsd:documentation>
|
||||
</xsd:annotation>
|
||||
</xsd:attribute>
|
||||
<xsd:attribute name="is-reader-transactional-queue" type="xsd:string" use="optional">
|
||||
<xsd:attribute name="reader-transactional-queue" type="xsd:string" use="optional">
|
||||
<xsd:annotation>
|
||||
<xsd:documentation><![CDATA[
|
||||
Whether the reader is a transactional queue. If it is then items read should not be cached
|
||||
|
||||
@@ -96,7 +96,7 @@ public class StepWithFaultTolerantProcessTaskJobParserTests {
|
||||
"isolation"));
|
||||
assertEquals("wrong transaction-attribute:", 10, ReflectionTestUtils.getField(factory, "transactionTimeout"));
|
||||
Object txq = ReflectionTestUtils.getField(factory, "isReaderTransactionalQueue");
|
||||
assertEquals("wrong is-reader-transactional-queue:", true, txq);
|
||||
assertEquals("wrong reader-transactional-queue:", true, txq);
|
||||
Object te = ReflectionTestUtils.getField(factory, "taskExecutor");
|
||||
assertEquals("wrong task-executor:", ConcurrentTaskExecutor.class, te.getClass());
|
||||
Object listeners = ReflectionTestUtils.getField(factory, "listeners");
|
||||
|
||||
@@ -10,7 +10,7 @@
|
||||
<step id="step">
|
||||
<tasklet task-executor="taskExecutor">
|
||||
<chunk reader="reader" processor="processor" writer="writer" commit-interval="10" skip-limit="20"
|
||||
retry-limit="3" cache-capacity="100" is-reader-transactional-queue="true">
|
||||
retry-limit="3" cache-capacity="100" reader-transactional-queue="true">
|
||||
<retry-listeners>
|
||||
<listener ref="retryListener">
|
||||
<beans:bean class="org.springframework.batch.core.configuration.xml.TestRetryListener"/>
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
<step id="step">
|
||||
<tasklet start-limit="25" allow-start-if-complete="true" task-executor="taskExecutor" throttle-limit="10">
|
||||
<chunk reader="reader" processor="processor" writer="writer" commit-interval="10" skip-limit="20"
|
||||
retry-limit="3" cache-capacity="100" is-reader-transactional-queue="true">
|
||||
retry-limit="3" cache-capacity="100" reader-transactional-queue="true">
|
||||
<retry-listeners>
|
||||
<listener>
|
||||
<beans:bean class="org.springframework.batch.core.configuration.xml.TestRetryListener" />
|
||||
|
||||
@@ -11,7 +11,7 @@
|
||||
<tasklet task-executor="taskExecutor">
|
||||
<chunk reader="reader" processor="processor" writer="writer"
|
||||
commit-interval="10" skip-limit="20" retry-limit="3" cache-capacity="100"
|
||||
is-reader-transactional-queue="true">
|
||||
reader-transactional-queue="true">
|
||||
|
||||
<retry-listeners>
|
||||
<listener ref="retryListener" />
|
||||
|
||||
Reference in New Issue
Block a user