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);