Repository: camel Updated Branches: refs/heads/fix-8478 [created] 689cee2b9
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/689cee2b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/689cee2b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/689cee2b Branch: refs/heads/fix-8478 Commit: 689cee2b9654d4924cc98c769a09f09b5ea10c8c Parents: 4f1cf5a Author: Andrea Cosentino <anco...@gmail.com> Authored: Thu Jul 2 22:45:23 2015 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Thu Jul 2 22:46:06 2015 +0200 ---------------------------------------------------------------------- .../camel/management/mbean/ManagedIdempotentConsumer.java | 6 +++--- .../apache/camel/processor/idempotent/IdempotentConsumer.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/689cee2b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedIdempotentConsumer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedIdempotentConsumer.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedIdempotentConsumer.java index 4aed45c..f1e5170 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedIdempotentConsumer.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedIdempotentConsumer.java @@ -44,9 +44,9 @@ public class ManagedIdempotentConsumer extends ManagedProcessor implements Manag getProcessor().resetDuplicateMessageCount(); } - @Override - public void clear() { + @Override + public void clear() { getProcessor().clear(); - } + } } http://git-wip-us.apache.org/repos/asf/camel/blob/689cee2b/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 afa80be..1faab20 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 @@ -200,9 +200,9 @@ public class IdempotentConsumer extends ServiceSupport implements AsyncProcessor /** * Clear the idempotent repository */ - public void clear() { - idempotentRepository.clear(); - } + public void clear() { + idempotentRepository.clear(); + } /** * A strategy method to allow derived classes to overload the behaviour of
