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 2017/03/03 19:36:30 UTC
[07/14] camel git commit: Removed unnecessary synchronized block.
Removed unnecessary synchronized block.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/64620c70
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/64620c70
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/64620c70
Branch: refs/heads/master
Commit: 64620c70d97e2a5cfe030efef083dfa3ce767005
Parents: 726890f
Author: Jakub Korab <ja...@gmail.com>
Authored: Thu Mar 2 15:20:40 2017 +0000
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Mar 3 20:03:08 2017 +0100
----------------------------------------------------------------------
.../idempotent/kafka/KafkaIdempotentRepository.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/64620c70/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java b/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java
index 8a1b8e1..0303996 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java
@@ -194,13 +194,11 @@ public class KafkaIdempotentRepository extends ServiceSupport implements Idempot
@ManagedOperation(description = "Does the store contain the given key")
public boolean contains(String key) {
LOG.debug("Checking cache for key:{}", key);
- synchronized (cache) {
- boolean containsKey = cache.containsKey(key);
- if (containsKey) {
- duplicateCount.incrementAndGet();
- }
- return containsKey;
+ boolean containsKey = cache.containsKey(key);
+ if (containsKey) {
+ duplicateCount.incrementAndGet();
}
+ return containsKey;
}
@Override