You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2012/05/05 11:43:02 UTC
svn commit: r1334366 -
/camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/processor/idempotent/KratiIdempotentRepository.java
Author: davsclaus
Date: Sat May 5 09:43:01 2012
New Revision: 1334366
URL: http://svn.apache.org/viewvc?rev=1334366&view=rev
Log:
Polished
Modified:
camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/processor/idempotent/KratiIdempotentRepository.java
Modified: camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/processor/idempotent/KratiIdempotentRepository.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/processor/idempotent/KratiIdempotentRepository.java?rev=1334366&r1=1334365&r2=1334366&view=diff
==============================================================================
--- camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/processor/idempotent/KratiIdempotentRepository.java (original)
+++ camel/trunk/components/camel-krati/src/main/java/org/apache/camel/component/krati/processor/idempotent/KratiIdempotentRepository.java Sat May 5 09:43:01 2012
@@ -41,7 +41,6 @@ public class KratiIdempotentRepository e
public KratiIdempotentRepository(String repositoryPath) {
this.repositoryPath = repositoryPath;
-
}
@Override
@@ -70,7 +69,7 @@ public class KratiIdempotentRepository e
try {
return dataSet.has(bytes);
} catch (Exception e) {
- LOG.warn("Error adding item to krati idempotent repository. This exception is ignored.", e);
+ LOG.warn("Error checking item exists in krati idempotent repository. This exception is ignored.", e);
return false;
}
}
@@ -82,7 +81,7 @@ public class KratiIdempotentRepository e
try {
return dataSet.delete(bytes);
} catch (Exception e) {
- LOG.warn("Error adding item to krati idempotent repository. This exception is ignored.", e);
+ LOG.warn("Error removing item from krati idempotent repository. This exception is ignored.", e);
return false;
}
}