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;
}
}