Repository: camel Updated Branches: refs/heads/master 2ab36a3db -> 44f881e0c
Fixed some Eclipse warning of aggregater Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8f24ca30 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8f24ca30 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8f24ca30 Branch: refs/heads/master Commit: 8f24ca30794b11becf61e54a2b0908f22c886609 Parents: 2ab36a3 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Fri Apr 4 21:45:30 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Fri Apr 4 21:45:30 2014 +0800 ---------------------------------------------------------------------- .../processor/aggregate/AbstractListAggregationStrategy.java | 6 ++++-- .../aggregate/GroupedExchangeAggregationStrategy.java | 4 ++-- 2 files changed, 6 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/8f24ca30/camel-core/src/main/java/org/apache/camel/processor/aggregate/AbstractListAggregationStrategy.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AbstractListAggregationStrategy.java b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AbstractListAggregationStrategy.java index ae382dc..ad2ec8e 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AbstractListAggregationStrategy.java +++ b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AbstractListAggregationStrategy.java @@ -100,7 +100,7 @@ public abstract class AbstractListAggregationStrategy<V> implements CompletionAw private List<V> getList(Exchange exchange) { List<V> list = exchange.getProperty(Exchange.GROUPED_EXCHANGE, List.class); if (list == null) { - list = new GroupedExchangeList(); + list = new GroupedExchangeList<V>(); exchange.setProperty(Exchange.GROUPED_EXCHANGE, list); } return list; @@ -109,7 +109,9 @@ public abstract class AbstractListAggregationStrategy<V> implements CompletionAw /** * A list to contains grouped {@link Exchange}s. */ - private static final class GroupedExchangeList extends ArrayList { + private static final class GroupedExchangeList<E> extends ArrayList<E> { + + private static final long serialVersionUID = 1L; @Override public String toString() { http://git-wip-us.apache.org/repos/asf/camel/blob/8f24ca30/camel-core/src/main/java/org/apache/camel/processor/aggregate/GroupedExchangeAggregationStrategy.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/aggregate/GroupedExchangeAggregationStrategy.java b/camel-core/src/main/java/org/apache/camel/processor/aggregate/GroupedExchangeAggregationStrategy.java index 587746c..84b375d 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/aggregate/GroupedExchangeAggregationStrategy.java +++ b/camel-core/src/main/java/org/apache/camel/processor/aggregate/GroupedExchangeAggregationStrategy.java @@ -29,12 +29,12 @@ import org.apache.camel.Exchange; public class GroupedExchangeAggregationStrategy extends AbstractListAggregationStrategy<Exchange> { @Override - @SuppressWarnings("unchecked") + public void onCompletion(Exchange exchange) { if (isStoreAsBodyOnCompletion()) { // lets be backwards compatible // TODO: Remove this method in Camel 3.0 - List list = (List) exchange.getProperty(Exchange.GROUPED_EXCHANGE); + List<?> list = (List<?>) exchange.getProperty(Exchange.GROUPED_EXCHANGE); if (list != null) { exchange.getIn().setBody(list); }
