svn commit: r702404 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java

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

svn commit: r702404 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java

gertv-2
Author: gertv
Date: Tue Oct  7 02:11:31 2008
New Revision: 702404

URL: http://svn.apache.org/viewvc?rev=702404&view=rev
Log:
CAMEL-951: little change required to make it compile with Java 6

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java?rev=702404&r1=702403&r2=702404&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/PredicateAggregationCollection.java Tue Oct  7 02:11:31 2008
@@ -40,7 +40,7 @@
     }
 
     @Override
-    protected void onAggregation(Object correlationKey, Exchange newExchange) {
+    public void onAggregation(Object correlationKey, Exchange newExchange) {
         if (aggregationCompletedPredicate.matches(newExchange)) {
             // this exchange has now aggregated so lets add it to the collection of things to send
             super.getMap().remove(correlationKey);