svn commit: r702363 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor: BatchProcessor.java aggregate/AggregationCollection.java aggregate/DefaultAggregationCollection.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r702363 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor: BatchProcessor.java aggregate/AggregationCollection.java aggregate/DefaultAggregationCollection.java

davsclaus-2
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 {@link #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 {@link 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 {@link 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() {