Repository: camel Updated Branches: refs/heads/master 192a3b2bc -> 97cd326de
Add a couple of tests for PollEnricher Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/97cd326d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/97cd326d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/97cd326d Branch: refs/heads/master Commit: 97cd326dedf0872ce5ef910df0f8f00fc844461a Parents: 192a3b2 Author: Andrea Cosentino <anco...@gmail.com> Authored: Fri Mar 4 15:50:09 2016 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Fri Mar 4 15:50:43 2016 +0100 ---------------------------------------------------------------------- ...EnrichFileCustomAggregationStrategyTest.java | 83 ++++++++++++++++++++ ...nrichFileDefaultAggregationStrategyTest.java | 69 ++++++++++++++++ 2 files changed, 152 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/97cd326d/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java b/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java new file mode 100644 index 0000000..4e46667 --- /dev/null +++ b/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java @@ -0,0 +1,83 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.camel.processor.enricher; + +import java.io.File; +import java.io.FileWriter; +import java.util.List; + +import org.apache.camel.ContextTestSupport; +import org.apache.camel.Exchange; +import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.processor.aggregate.AggregationStrategy; +import org.junit.Test; + +public class PollEnrichFileCustomAggregationStrategyTest extends ContextTestSupport { + + @Test + public void testPollEnrichDefaultAggregationStrategyBody() throws Exception { + + Thread.sleep(2000); + String enrichFilename = "target/pollEnrich/enrich.txt"; + String msgText = "Hello Camel"; + FileWriter enrichFile = new FileWriter(enrichFilename); + enrichFile.write(msgText); + enrichFile.close(); + + getMockEndpoint("mock:result").expectedMinimumMessageCount(1); + + assertMockEndpointsSatisfied(); + + List<Exchange> exchanges = getMockEndpoint("mock:result").getExchanges(); + assertEquals(1, exchanges.size()); + Exchange ex = (Exchange) exchanges.get(0); + assertEquals(msgText, ex.getIn().getBody().toString()); + + //This file should be deleted but it's there when the test end, so we have to use AssertTrue for the moment + Thread.sleep(300); + File markerFile = new File(enrichFilename + ".camelLock"); + assertTrue("Camel markerFile " + enrichFilename + ".camelLock did not get deleted after file consumption.", markerFile.exists()); + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("timer:foo?period=1000&repeatCount=1") + .setBody().constant("Hello from Camel.") + .pollEnrich("file:target/pollEnrich?fileName=enrich.txt&readLock=markerFile", new ReplaceAggregationStrategy()) + .convertBodyTo(String.class) + .log("The body is ${body}") + .to("mock:result"); + } + }; + } + + class ReplaceAggregationStrategy implements AggregationStrategy { + + public Exchange aggregate(Exchange original, Exchange resource) { + Object resourceResponse = resource.getIn().getBody(); + if (original.getPattern().isOutCapable()) { + original.getOut().setBody(resourceResponse); + } else { + original.getIn().setBody(resourceResponse); + } + return original; + } + } +} http://git-wip-us.apache.org/repos/asf/camel/blob/97cd326d/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileDefaultAggregationStrategyTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileDefaultAggregationStrategyTest.java b/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileDefaultAggregationStrategyTest.java new file mode 100644 index 0000000..73f6dcd --- /dev/null +++ b/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileDefaultAggregationStrategyTest.java @@ -0,0 +1,69 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.camel.processor.enricher; + +import java.io.File; +import java.io.FileWriter; +import java.util.List; + +import org.apache.camel.ContextTestSupport; +import org.apache.camel.Exchange; +import org.apache.camel.builder.RouteBuilder; +import org.junit.Test; + +public class PollEnrichFileDefaultAggregationStrategyTest extends ContextTestSupport { + + @Test + public void testPollEnrichDefaultAggregationStrategyBody() throws Exception { + + Thread.sleep(2000); + String enrichFilename = "target/pollEnrich/enrich.txt"; + String msgText = "Hello Camel"; + FileWriter enrichFile = new FileWriter(enrichFilename); + enrichFile.write(msgText); + enrichFile.close(); + + getMockEndpoint("mock:result").expectedMinimumMessageCount(1); + + assertMockEndpointsSatisfied(); + + List<Exchange> exchanges = getMockEndpoint("mock:result").getExchanges(); + assertEquals(1, exchanges.size()); + Exchange ex = (Exchange) exchanges.get(0); + assertEquals(msgText, ex.getIn().getBody().toString()); + + // assert Camel markerFile got deleted + Thread.sleep(300); + File markerFile = new File(enrichFilename + ".camelLock"); + assertFalse("Camel markerFile " + enrichFilename + ".camelLock did not get deleted after file consumption.", markerFile.exists()); + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("timer:foo?period=1000&repeatCount=1") + .setBody().constant("Hello from Camel.") + .pollEnrich("file:target/pollEnrich?fileName=enrich.txt&readLock=markerFile") + .convertBodyTo(String.class) + .log("The body is ${body}") + .to("mock:result"); + } + }; + } +}
