camel git commit: CAMEL-10454 fix key check

[ningjiang]

Repository: camel
Updated Branches:
  refs/heads/camel-2.17.x 95a7ed63f -> 5aa56a5b6


CAMEL-10454 fix key check


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

Branch: refs/heads/camel-2.17.x
Commit: 5aa56a5b6c3597873eae777e3023932d45b1367f
Parents: 95a7ed6
Author: Kevin Earls 
Authored: Mon Nov 14 20:29:17 2016 +0100
Committer: Willem Jiang 
Committed: Tue Nov 15 11:22:28 2016 +0800

--
 .../org/apache/camel/processor/idempotent/IdempotentConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/camel/blob/5aa56a5b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
--
diff --git 
a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
 
b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
index b4fb4f4..46521aa 100644
--- 
a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
+++ 
b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
@@ -132,7 +132,7 @@ public class IdempotentConsumer extends ServiceSupport 
implements CamelContextAw
 } else {
 // check if we already have the key
 if (idempotentRepository instanceof 
ExchangeIdempotentRepository) {
-newKey = ((ExchangeIdempotentRepository) 
idempotentRepository).contains(exchange, messageId);
+newKey = !((ExchangeIdempotentRepository) 
idempotentRepository).contains(exchange, messageId);
 } else {
 newKey = !idempotentRepository.contains(messageId);
 }

[2/2] camel git commit: CAMEL-10454 fix key check

[ningjiang]

CAMEL-10454 fix key check


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

Branch: refs/heads/camel-2.18.x
Commit: 3f346ea84c3e97d05f55f29bfeaa37f6159b8da7
Parents: 27b572d
Author: Kevin Earls 
Authored: Mon Nov 14 20:29:17 2016 +0100
Committer: Willem Jiang 
Committed: Tue Nov 15 10:57:02 2016 +0800

--
 .../org/apache/camel/processor/idempotent/IdempotentConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/camel/blob/3f346ea8/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
--
diff --git 
a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
 
b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
index b4fb4f4..46521aa 100644
--- 
a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
+++ 
b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
@@ -132,7 +132,7 @@ public class IdempotentConsumer extends ServiceSupport 
implements CamelContextAw
 } else {
 // check if we already have the key
 if (idempotentRepository instanceof 
ExchangeIdempotentRepository) {
-newKey = ((ExchangeIdempotentRepository) 
idempotentRepository).contains(exchange, messageId);
+newKey = !((ExchangeIdempotentRepository) 
idempotentRepository).contains(exchange, messageId);
 } else {
 newKey = !idempotentRepository.contains(messageId);
 }

camel git commit: CAMEL-10454 fix key check

[ningjiang]

Repository: camel
Updated Branches:
  refs/heads/master 7d46782a7 -> 762010031


CAMEL-10454 fix key check


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

Branch: refs/heads/master
Commit: 762010031d0775f3b803a968fb2e0c2696fd7d75
Parents: 7d46782
Author: Kevin Earls 
Authored: Mon Nov 14 20:29:17 2016 +0100
Committer: Willem Jiang 
Committed: Tue Nov 15 10:44:19 2016 +0800

--
 .../org/apache/camel/processor/idempotent/IdempotentConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/camel/blob/76201003/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
--
diff --git 
a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
 
b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
index b4fb4f4..46521aa 100644
--- 
a/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
+++ 
b/camel-core/src/main/java/org/apache/camel/processor/idempotent/IdempotentConsumer.java
@@ -132,7 +132,7 @@ public class IdempotentConsumer extends ServiceSupport 
implements CamelContextAw
 } else {
 // check if we already have the key
 if (idempotentRepository instanceof 
ExchangeIdempotentRepository) {
-newKey = ((ExchangeIdempotentRepository) 
idempotentRepository).contains(exchange, messageId);
+newKey = !((ExchangeIdempotentRepository) 
idempotentRepository).contains(exchange, messageId);
 } else {
 newKey = !idempotentRepository.contains(messageId);
 }