camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [05/13] camel git commit: CAMEL-8478: IdempotentRepository - Add clear operation, align HazelcastIdempotentRepository
Date Fri, 03 Jul 2015 20:23:49 GMT
CAMEL-8478: IdempotentRepository - Add clear operation, align HazelcastIdempotentRepository


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

Branch: refs/heads/master
Commit: da71c7b6b3349b46a3190140f23a368e2f5f835f
Parents: e12ff48
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Fri Jul 3 17:07:52 2015 +0200
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Fri Jul 3 17:07:52 2015 +0200

----------------------------------------------------------------------
 .../hazelcast/HazelcastIdempotentRepository.java        |  6 +++++-
 .../hazelcast/HazelcastIdempotentRepositoryTest.java    | 12 ++++++++++++
 2 files changed, 17 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/da71c7b6/components/camel-hazelcast/src/main/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepository.java
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepository.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepository.java
index 4061240..fcd92ab 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepository.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepository.java
@@ -85,9 +85,13 @@ public class HazelcastIdempotentRepository extends ServiceSupport implements
Ide
             repo.unlock(key);
         }
     }
+    
+    @Override
+    public void clear() {
+        repo.clear();        
+    }
 
     public String getRepositoryName() {
         return repositoryName;
     }
-
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/da71c7b6/components/camel-hazelcast/src/test/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepositoryTest.java
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/test/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepositoryTest.java
b/components/camel-hazelcast/src/test/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepositoryTest.java
index 15fbae9..8d09d87 100644
--- a/components/camel-hazelcast/src/test/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepositoryTest.java
+++ b/components/camel-hazelcast/src/test/java/org/apache/camel/processor/idempotent/hazelcast/HazelcastIdempotentRepositoryTest.java
@@ -88,6 +88,18 @@ public class HazelcastIdempotentRepositoryTest extends CamelTestSupport
{
     public void testRemove() throws Exception {
         // add key to remove
         assertTrue(repo.add(key01));
+        assertTrue(repo.add(key02));
+        assertEquals(2, cache.size());
+
+        // clear repo
+        repo.clear();
+        assertEquals(0, cache.size());
+    }
+    
+    @Test
+    public void testClear() throws Exception {
+        // add key to remove
+        assertTrue(repo.add(key01));
         assertEquals(1, cache.size());
 
         // remove key


Mime
View raw message