camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [3/4] camel git commit: Hazelcast :: Aggregation Repository
Date Mon, 29 Feb 2016 07:43:50 GMT
Hazelcast :: Aggregation Repository

Removes clear cache operation at stop.
As Hazelcast is used in a clustered environment, clearing the cache when the bundle
stops prevents other instances running somewhere else to take over the pending
aggregations.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c7e57023
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c7e57023
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c7e57023

Branch: refs/heads/camel-2.16.x
Commit: c7e57023e177e779ce2b40701a15b7276d0d987a
Parents: b7624cb
Author: Frederic Gendebien <frederic.gendebien@gmail.com>
Authored: Sat Feb 27 20:36:50 2016 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Mon Feb 29 08:43:21 2016 +0100

----------------------------------------------------------------------
 .../aggregate/hazelcast/HazelcastAggregationRepository.java     | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/c7e57023/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 65207c2..e4a6723 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
@@ -399,10 +399,7 @@ public class HazelcastAggregationRepository extends ServiceSupport
 
     @Override
     protected void doStop() throws Exception {
-        if (useRecovery) {
-            persistedCache.clear();
-        }
-        cache.clear();
+        //noop
         if (useLocalHzInstance) {
             hzInstance.getLifecycleService().shutdown();
         }


Mime
View raw message