From 5fcd4e54b4703daa8b929211d3817ef9ffd0fb15 Mon Sep 17 00:00:00 2001 From: lucasward Date: Mon, 21 Jul 2008 04:25:44 +0000 Subject: [PATCH] BATCH-711:Modified ItemWriter interface to use parameterized types. Updated a portion of classes using ItemWriter as well. --- .../batch/jms/ExternalRetryInBatchTests.java | 2 +- .../batch/retry/jms/ExternalRetryTests.java | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/jms/ExternalRetryInBatchTests.java b/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/jms/ExternalRetryInBatchTests.java index b8c439224..c9ea5825d 100644 --- a/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/jms/ExternalRetryInBatchTests.java +++ b/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/jms/ExternalRetryInBatchTests.java @@ -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 implements ItemRecoverer { } } diff --git a/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/retry/jms/ExternalRetryTests.java b/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/retry/jms/ExternalRetryTests.java index 4b8e4cb85..2bf186fcc 100644 --- a/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/retry/jms/ExternalRetryTests.java +++ b/spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/retry/jms/ExternalRetryTests.java @@ -46,7 +46,7 @@ public class ExternalRetryTests extends AbstractDependencyInjectionSpringContext private RetryTemplate retryTemplate; - private ItemReaderRecoverer provider; + private ItemReaderRecoverer 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() { + 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 writer = new AbstractItemWriter() { 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 extends AbstractItemReader implements ItemRecoverer { }