Repository: camel Updated Branches: refs/heads/master 2feb85a86 -> c4338c650
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c5674e84 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c5674e84 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c5674e84 Branch: refs/heads/master Commit: c5674e84fdc5e8aa5824d8d3958dc0ec354d3da5 Parents: 5d19e38 Author: Andrea Cosentino <anco...@gmail.com> Authored: Thu Jul 2 22:45:23 2015 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Fri Jul 3 15:09:24 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/c5674e84/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/c5674e84/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
