simplified the unit test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/50d661fe Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/50d661fe Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/50d661fe Branch: refs/heads/master Commit: 50d661fe1317ece724cb2f68c7b5f89f4a3fe5ad Parents: d1d9f4a Author: cmueller <cmuel...@apache.org> Authored: Thu May 23 23:45:21 2013 +0200 Committer: cmueller <cmuel...@apache.org> Committed: Thu May 23 23:45:21 2013 +0200 ---------------------------------------------------------------------- .../spring/batch/SpringBatchIntegrationTest.java | 19 ++++----------- 1 files changed, 5 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/50d661fe/components/camel-spring-batch/src/test/java/org/apache/camel/component/spring/batch/SpringBatchIntegrationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/test/java/org/apache/camel/component/spring/batch/SpringBatchIntegrationTest.java b/components/camel-spring-batch/src/test/java/org/apache/camel/component/spring/batch/SpringBatchIntegrationTest.java index 74dc734..12e9f80 100644 --- a/components/camel-spring-batch/src/test/java/org/apache/camel/component/spring/batch/SpringBatchIntegrationTest.java +++ b/components/camel-spring-batch/src/test/java/org/apache/camel/component/spring/batch/SpringBatchIntegrationTest.java @@ -24,8 +24,6 @@ import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; -import static org.junit.Assert.assertTrue; - public class SpringBatchIntegrationTest { ApplicationContext applicationContext; @@ -36,7 +34,7 @@ public class SpringBatchIntegrationTest { MockEndpoint jobExecutionEventsQueueEndpoint; - String[] inputMessages; + String[] inputMessages = new String[]{"foo", "bar", "baz", null}; @Before public void setUp() { @@ -44,34 +42,27 @@ public class SpringBatchIntegrationTest { producerTemplate = applicationContext.getBean(ProducerTemplate.class); outputEndpoint = applicationContext.getBean(CamelContext.class).getEndpoint("mock:output", MockEndpoint.class); jobExecutionEventsQueueEndpoint = applicationContext.getBean(CamelContext.class).getEndpoint("mock:jobExecutionEventsQueue", MockEndpoint.class); - inputMessages = new String[]{"foo", "bar", "baz"}; for (String message : inputMessages) { producerTemplate.sendBody("seda:inputQueue", message); } - producerTemplate.sendBody("seda:inputQueue", null); - } @Test public void shouldEchoInBatch() throws InterruptedException { - // When + outputEndpoint.expectedBodiesReceived("Echo foo", "Echo bar", "Echo baz"); + producerTemplate.sendBody("direct:start", "Start batch!"); - // Then - outputEndpoint.setExpectedMessageCount(inputMessages.length); outputEndpoint.assertIsSatisfied(); - assertTrue(outputEndpoint.getExchanges().get(0).getIn().getBody(String.class).startsWith("Echo ")); } @Test public void shouldGenerateBatchExecutionEvents() throws InterruptedException { - // When + jobExecutionEventsQueueEndpoint.setExpectedMessageCount(2); + producerTemplate.sendBody("direct:start", "Start batch!"); - // Then - jobExecutionEventsQueueEndpoint.setExpectedMessageCount(2); jobExecutionEventsQueueEndpoint.assertIsSatisfied(); } - }
