CAMEL-9014: More endpoint usage statitics on the runtime endpoint mbean
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3bb5ee21 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3bb5ee21 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3bb5ee21 Branch: refs/heads/master Commit: 3bb5ee21c3c3cdd03d79ff4c0ce24bb2563db3e1 Parents: 27017c8 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jul 26 15:03:14 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jul 26 15:03:14 2015 +0200 ---------------------------------------------------------------------- .../mbean/ManagedRuntimeEndpointRegistryMBean.java | 6 ++++++ .../management/mbean/ManagedRuntimeEndpointRegistry.java | 10 ++++++++++ 2 files changed, 16 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3bb5ee21/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRuntimeEndpointRegistryMBean.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRuntimeEndpointRegistryMBean.java b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRuntimeEndpointRegistryMBean.java index b63d3f1..2199c7d 100644 --- a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRuntimeEndpointRegistryMBean.java +++ b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRuntimeEndpointRegistryMBean.java @@ -34,6 +34,12 @@ public interface ManagedRuntimeEndpointRegistryMBean extends ManagedServiceMBean @ManagedAttribute(description = "Whether gathering runtime usage is enabled or not.") void setEnabled(boolean enabled); + @ManagedAttribute(description = "Maximum number of endpoints to keep in the cache per route.") + int getLimit(); + + @ManagedAttribute(description = "Number of endpoints currently in the cache.") + int size(); + @ManagedOperation(description = " Gets all the endpoint uris captured during runtime that are in-use.") List<String> getAllEndpoints(boolean includeInputs); http://git-wip-us.apache.org/repos/asf/camel/blob/3bb5ee21/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRuntimeEndpointRegistry.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRuntimeEndpointRegistry.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRuntimeEndpointRegistry.java index 74efaba..c93d2c6 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRuntimeEndpointRegistry.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRuntimeEndpointRegistry.java @@ -66,6 +66,16 @@ public class ManagedRuntimeEndpointRegistry extends ManagedService implements Ma } @Override + public int getLimit() { + return registry.getLimit(); + } + + @Override + public int size() { + return registry.size(); + } + + @Override public List<String> getAllEndpoints(boolean includeInputs) { return registry.getAllEndpoints(includeInputs); }
