Repository: camel Updated Branches: refs/heads/camel-2.16.x 3e1c3a62b -> b93b773c0
added method to check for key existence Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a212a423 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a212a423 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a212a423 Branch: refs/heads/camel-2.16.x Commit: a212a42365e204af4201118c5e1ae266c7e2b030 Parents: 3e1c3a6 Author: Michael Lück <michael.lu...@hm-ag.de> Authored: Tue Oct 4 11:18:04 2016 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Wed Oct 12 13:02:18 2016 +0200 ---------------------------------------------------------------------- .../aggregate/hazelcast/HazelcastAggregationRepository.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a212a423/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java ---------------------------------------------------------------------- diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java index e4a6723..a1bb1cd 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java @@ -288,6 +288,15 @@ public class HazelcastAggregationRepository extends ServiceSupport public Exchange get(CamelContext camelContext, String key) { return unmarshallExchange(camelContext, cache.get(key)); } + + /** + * Checks if the key in question is in the repository. + * + * @param key Object - key in question + */ + public boolean containsKey(Object key){ + return cache.containsKey(key); + } /** * This method performs transactional operation on removing the {@code exchange}
