Author: davsclaus
Date: Tue Oct 7 00:16:21 2008
New Revision: 702363
URL: http://svn.apache.org/viewvc?rev=702363&view=rev
Log:
CAMEL-951: Polished code
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregationCollection.java
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/DefaultAggregationCollection.java
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java?rev=702363&r1=702362&r2=702363&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
(original)
+++
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
Tue Oct 7 00:16:21 2008
@@ -91,7 +91,7 @@
}
/**
- * Sets the <b>in</b> batch size. This is the number of incomiing
exchanges that this batch processor
+ * Sets the <b>in</b> batch size. This is the number of incoming exchanges
that this batch processor
* will process before its completed. The default value is [EMAIL
PROTECTED] #DEFAULT_BATCH_SIZE}.
*
* @param batchSize the size
@@ -107,7 +107,7 @@
/**
* Sets the <b>out</b> batch size. If the batch processor holds more
exchanges than this out size then
* the completion is triggered. Can for instance be used to ensure that
this batch is completed when
- * a certain number of exchanges has been collected. By default this
feature is <b>not</b> used.
+ * a certain number of exchanges has been collected. By default this
feature is <b>not</b> enabled.
*
* @param outBatchSize the size
*/
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregationCollection.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregationCollection.java?rev=702363&r1=702362&r2=702363&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregationCollection.java
(original)
+++
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregationCollection.java
Tue Oct 7 00:16:21 2008
@@ -57,4 +57,10 @@
*/
void clear();
+ /**
+ * A strategy method allowing derived classes such as [EMAIL PROTECTED]
PredicateAggregationCollection}
+ * to check to see if the aggregation has completed
+ */
+ void onAggregation(Object correlationKey, Exchange newExchange);
+
}
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/DefaultAggregationCollection.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/DefaultAggregationCollection.java?rev=702363&r1=702362&r2=702363&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/DefaultAggregationCollection.java
(original)
+++
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/DefaultAggregationCollection.java
Tue Oct 7 00:16:21 2008
@@ -93,11 +93,7 @@
map.clear();
}
- /**
- * A strategy method allowing derived classes such as [EMAIL PROTECTED]
PredicateAggregationCollection}
- * to check to see if the aggregation has completed
- */
- protected void onAggregation(Object correlationKey, Exchange newExchange) {
+ public void onAggregation(Object correlationKey, Exchange newExchange) {
}
public Expression<Exchange> getCorrelationExpression() {
