You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2009/02/04 15:55:58 UTC
svn commit: r740762 - in /camel/trunk/camel-core/src:
main/java/org/apache/camel/processor/interceptor/StreamCaching.java
test/java/org/apache/camel/processor/AggregatorTest.java
test/java/org/apache/camel/processor/SplitterTest.java
Author: janstey
Date: Wed Feb 4 14:55:57 2009
New Revision: 740762
URL: http://svn.apache.org/viewvc?rev=740762&view=rev
Log:
typos and CS errors
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/StreamCaching.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/StreamCaching.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/StreamCaching.java?rev=740762&r1=740761&r2=740762&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/StreamCaching.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/interceptor/StreamCaching.java Wed Feb 4 14:55:57 2009
@@ -24,7 +24,7 @@
/**
* {@link InterceptStrategy} implementation to configure stream caching on a RouteContext
*/
-public class StreamCaching implements InterceptStrategy {
+public final class StreamCaching implements InterceptStrategy {
/*
* Hide constructor -- instances will be created through static enable() methods
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java?rev=740762&r1=740761&r2=740762&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java Wed Feb 4 14:55:57 2009
@@ -88,7 +88,7 @@
from("seda:header").setHeader("visited", constant(true)).aggregate(header("cheese")).to("mock:result");
- // in this sample we aggregate using our own startegy with a completion predicate
+ // in this sample we aggregate using our own strategy with a completion predicate
// stating that the aggregated header is equal to 5.
from("direct:predicate").aggregate(header("cheese"), new MyAggregationStrategy()).
completedPredicate(header("aggregated").isEqualTo(5)).to("mock:result");
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java?rev=740762&r1=740761&r2=740762&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterTest.java Wed Feb 4 14:55:57 2009
@@ -58,7 +58,7 @@
}
}
- public void testSpliterWithAggregationStrategy() throws Exception {
+ public void testSplitterWithAggregationStrategy() throws Exception {
MockEndpoint resultEndpoint = getMockEndpoint("mock:result");
resultEndpoint.expectedBodiesReceived("James", "Guillaume", "Hiram", "Rob", "Roman");
@@ -122,7 +122,7 @@
assertEquals(4, numbersFound.size());
}
- public void testSpliterWithAggregationStrategyParallel() throws Exception {
+ public void testSplitterWithAggregationStrategyParallel() throws Exception {
MockEndpoint resultEndpoint = getMockEndpoint("mock:result");
resultEndpoint.expectedMessageCount(5);
@@ -141,7 +141,7 @@
assertEquals((Integer)5, result.getProperty("aggregated", Integer.class));
}
- public void testSpliterWithAggregationStrategyParallelStreaming() throws Exception {
+ public void testSplitterWithAggregationStrategyParallelStreaming() throws Exception {
MockEndpoint resultEndpoint = getMockEndpoint("mock:result");
resultEndpoint.expectedMessageCount(5);
resultEndpoint.expectedBodiesReceivedInAnyOrder("James", "Guillaume", "Hiram", "Rob", "Roman");