camel-commits mailing list archives

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


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

Branch: refs/heads/master
Commit: d070697d998e35a32a8d56885cf58c832d59467d
Parents: 84e1d5d
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Fri Jul 3 21:20:16 2015 +0200
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Fri Jul 3 21:20:16 2015 +0200

----------------------------------------------------------------------
 .../apache/camel/itest/idempotent/JdbcIdempotentRepository.java  | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/d070697d/tests/camel-itest/src/test/java/org/apache/camel/itest/idempotent/JdbcIdempotentRepository.java
----------------------------------------------------------------------
diff --git a/tests/camel-itest/src/test/java/org/apache/camel/itest/idempotent/JdbcIdempotentRepository.java
b/tests/camel-itest/src/test/java/org/apache/camel/itest/idempotent/JdbcIdempotentRepository.java
index c917ff0..cf4a45c 100644
--- a/tests/camel-itest/src/test/java/org/apache/camel/itest/idempotent/JdbcIdempotentRepository.java
+++ b/tests/camel-itest/src/test/java/org/apache/camel/itest/idempotent/JdbcIdempotentRepository.java
@@ -55,6 +55,10 @@ public class JdbcIdempotentRepository implements IdempotentRepository<String>
{
     public boolean confirm(String key) {
         return true;
     }
+    
+	public void clear() {
+		jdbc.update("DELETE * FROM ProcessedPayments");		
+	}
 
     public void start() throws Exception {
         // noop


Mime
View raw message