camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject camel git commit: CAMEL-8478: IdempotentRepository - Add clear operation, align RedisIdempotentRepository
Date Fri, 03 Jul 2015 22:00:32 GMT
Repository: camel
Updated Branches:
  refs/heads/master c4338c650 -> 51fca498b


CAMEL-8478: IdempotentRepository - Add clear operation, align RedisIdempotentRepository


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

Branch: refs/heads/master
Commit: 51fca498be8dbb7b3bf4a9d60dbbc3a042054d93
Parents: c4338c6
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Fri Jul 3 23:59:23 2015 +0200
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Fri Jul 3 23:59:23 2015 +0200

----------------------------------------------------------------------
 .../redis/processor/idempotent/RedisIdempotentRepository.java  | 5 +++++
 .../processor/idempotent/RedisIdempotentRepositoryTest.java    | 6 ++++++
 2 files changed, 11 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/51fca498/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepository.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepository.java
b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepository.java
index afe30c7..a1ef7ed 100755
--- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepository.java
+++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepository.java
@@ -70,6 +70,11 @@ public class RedisIdempotentRepository extends ServiceSupport implements
Idempot
     public boolean remove(String key) {
         return setOperations.remove(processorName, key) != null;
     }
+    
+    @ManagedOperation(description = "Clear the store")
+    public void clear() {
+        setOperations.remove(processorName);
+    }
 
     @ManagedAttribute(description = "The processor name")
     public String getProcessorName() {

http://git-wip-us.apache.org/repos/asf/camel/blob/51fca498/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepositoryTest.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepositoryTest.java
b/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepositoryTest.java
index 5fdc1a2..fd977ac 100755
--- a/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepositoryTest.java
+++ b/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis/processor/idempotent/RedisIdempotentRepositoryTest.java
@@ -58,6 +58,12 @@ public class RedisIdempotentRepositoryTest {
         idempotentRepository.remove(KEY);
         verify(setOperations).remove(REPOSITORY, KEY);
     }
+    
+    @Test
+    public void shouldClearRepository() {
+        idempotentRepository.clear();
+        verify(setOperations).remove(REPOSITORY);
+    }
 
     @Test
     public void shouldReturnProcessorName() {


Mime
View raw message