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

BATCH-711:Modified ItemWriter interface to use parameterized types. Updated a portion of classes using ItemWriter as well.

Browse Source
This commit is contained in:
lucasward
2008-07-21 04:25:44 +00:00
parent f1e73a7fa0
commit 5fcd4e54b4
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/jms/ExternalRetryInBatchTests.java
View File

@@ -209,7 +209,7 @@ public class ExternalRetryInBatchTests extends AbstractDependencyInjectionSpring
return msgs;
}
private abstract class ItemReaderRecoverer extends AbstractItemReader implements ItemRecoverer {
private abstract class ItemReaderRecoverer extends AbstractItemReader<Object> implements ItemRecoverer {
}
}

10
spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/retry/jms/ExternalRetryTests.java
View File

@@ -46,7 +46,7 @@ public class ExternalRetryTests extends AbstractDependencyInjectionSpringContext
private RetryTemplate retryTemplate;
private ItemReaderRecoverer provider;
private ItemReaderRecoverer<String> provider;
private JdbcTemplate jdbcTemplate;
@@ -74,8 +74,8 @@ public class ExternalRetryTests extends AbstractDependencyInjectionSpringContext
getMessages(); // drain queue
jdbcTemplate.execute("delete from T_FOOS");
jmsTemplate.convertAndSend("queue", "foo");
provider = new ItemReaderRecoverer() {
public Object read() {
provider = new ItemReaderRecoverer<String>() {
public String read() {
String text = (String) jmsTemplate.receiveAndConvert("queue");
list.add(text);
return text;
@@ -110,7 +110,7 @@ public class ExternalRetryTests extends AbstractDependencyInjectionSpringContext
retryTemplate.setRetryPolicy(new RecoveryCallbackRetryPolicy());
final AbstractItemWriter writer = new AbstractItemWriter() {
final AbstractItemWriter<Object> writer = new AbstractItemWriter<Object>() {
public void write(final Object text) {
jdbcTemplate.update("INSERT into T_FOOS (id,name,foo_date) values (?,?,null)", new Object[] {
new Integer(list.size()), text });
@@ -258,7 +258,7 @@ public class ExternalRetryTests extends AbstractDependencyInjectionSpringContext
return msgs;
}
private abstract class ItemReaderRecoverer extends AbstractItemReader implements ItemRecoverer {
private abstract class ItemReaderRecoverer<T> extends AbstractItemReader<T> implements ItemRecoverer {
}