CAMEL-9014: Option to turn on extended JMX statistics for EIPs to track fine grained utilization statistics such as which and how often they send to dynamic endpoints.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7609c0df Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7609c0df Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7609c0df Branch: refs/heads/master Commit: 7609c0df3a5dd1046b2a9f8cd99e13caeefe81cf Parents: 20ee173 Author: Claus Ibsen <davscl...@apache.org> Authored: Sat Jul 25 13:51:48 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat Jul 25 13:59:39 2015 +0200 ---------------------------------------------------------------------- .../apache/camel/management/mbean/ManagedDynamicRouter.java | 8 ++++++++ .../org/apache/camel/management/mbean/ManagedEnricher.java | 8 ++++++++ .../apache/camel/management/mbean/ManagedRecipientList.java | 8 ++++++++ .../apache/camel/management/mbean/ManagedRoutingSlip.java | 8 ++++++++ .../camel/management/mbean/ManagedSendDynamicProcessor.java | 8 ++++++++ .../camel/management/mbean/ManagedWireTapProcessor.java | 8 ++++++++ 6 files changed, 48 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/7609c0df/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDynamicRouter.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDynamicRouter.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDynamicRouter.java index e82d32d..c085d28 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDynamicRouter.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDynamicRouter.java @@ -64,6 +64,14 @@ public class ManagedDynamicRouter extends ManagedProcessor implements ManagedDyn } @Override + public synchronized void reset() { + super.reset(); + if (processor.getEndpointUtilizationStatistics() != null) { + processor.getEndpointUtilizationStatistics().clear(); + } + } + + @Override public String getExpression() { return uri; } http://git-wip-us.apache.org/repos/asf/camel/blob/7609c0df/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEnricher.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEnricher.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEnricher.java index a357774..7b480ce 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEnricher.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEnricher.java @@ -58,6 +58,14 @@ public class ManagedEnricher extends ManagedProcessor implements ManagedEnricher } @Override + public synchronized void reset() { + super.reset(); + if (processor.getEndpointUtilizationStatistics() != null) { + processor.getEndpointUtilizationStatistics().clear(); + } + } + + @Override public EnrichDefinition getDefinition() { return (EnrichDefinition) super.getDefinition(); } http://git-wip-us.apache.org/repos/asf/camel/blob/7609c0df/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRecipientList.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRecipientList.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRecipientList.java index 394459d..8cca08d 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRecipientList.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRecipientList.java @@ -59,6 +59,14 @@ public class ManagedRecipientList extends ManagedProcessor implements ManagedRec } @Override + public synchronized void reset() { + super.reset(); + if (processor.getEndpointUtilizationStatistics() != null) { + processor.getEndpointUtilizationStatistics().clear(); + } + } + + @Override public RecipientListDefinition getDefinition() { return (RecipientListDefinition) super.getDefinition(); } http://git-wip-us.apache.org/repos/asf/camel/blob/7609c0df/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoutingSlip.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoutingSlip.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoutingSlip.java index 1068c85..430a025 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoutingSlip.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoutingSlip.java @@ -59,6 +59,14 @@ public class ManagedRoutingSlip extends ManagedProcessor implements ManagedRouti } @Override + public synchronized void reset() { + super.reset(); + if (processor.getEndpointUtilizationStatistics() != null) { + processor.getEndpointUtilizationStatistics().clear(); + } + } + + @Override public RoutingSlipDefinition getDefinition() { return (RoutingSlipDefinition) super.getDefinition(); } http://git-wip-us.apache.org/repos/asf/camel/blob/7609c0df/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java index 0fb094b..fcc168d 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java @@ -58,6 +58,14 @@ public class ManagedSendDynamicProcessor extends ManagedProcessor implements Man } } + @Override + public synchronized void reset() { + super.reset(); + if (processor.getEndpointUtilizationStatistics() != null) { + processor.getEndpointUtilizationStatistics().clear(); + } + } + public SendDynamicProcessor getProcessor() { return processor; } http://git-wip-us.apache.org/repos/asf/camel/blob/7609c0df/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedWireTapProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedWireTapProcessor.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedWireTapProcessor.java index 1fad1ac..d4856ad 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedWireTapProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedWireTapProcessor.java @@ -58,6 +58,14 @@ public class ManagedWireTapProcessor extends ManagedProcessor implements Managed } } + @Override + public synchronized void reset() { + super.reset(); + if (processor.getEndpointUtilizationStatistics() != null) { + processor.getEndpointUtilizationStatistics().clear(); + } + } + public WireTapProcessor getProcessor() { return processor; }
