CAMEL-9019: ManagedRuntimeEndpointRegistry was not enlisted in JMX
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4f5c1d3a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4f5c1d3a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4f5c1d3a Branch: refs/heads/master Commit: 4f5c1d3ae61cf2d280f1217671e1db3f4101c2b9 Parents: a383842 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jul 26 14:45:56 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jul 26 14:45:56 2015 +0200 ---------------------------------------------------------------------- .../camel/management/DefaultManagementLifecycleStrategy.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4f5c1d3a/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java b/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java index 7d0f922..ab4db16 100644 --- a/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java +++ b/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java @@ -449,8 +449,6 @@ public class DefaultManagementLifecycleStrategy extends ServiceSupport implement managedBacklogDebuggers.put(backlogDebugger, md); } return md; - } else if (service instanceof EventNotifier) { - answer = getManagementObjectStrategy().getManagedObjectForEventNotifier(context, (EventNotifier) service); } else if (service instanceof Producer) { answer = getManagementObjectStrategy().getManagedObjectForProducer(context, (Producer) service); } else if (service instanceof Consumer) { @@ -478,6 +476,8 @@ public class DefaultManagementLifecycleStrategy extends ServiceSupport implement answer = new ManagedRuntimeEndpointRegistry(context, (RuntimeEndpointRegistry) service); } else if (service instanceof StreamCachingStrategy) { answer = new ManagedStreamCachingStrategy(context, (StreamCachingStrategy) service); + } else if (service instanceof EventNotifier) { + answer = getManagementObjectStrategy().getManagedObjectForEventNotifier(context, (EventNotifier) service); } else if (service != null) { // fallback as generic service answer = getManagementObjectStrategy().getManagedObjectForService(context, service);
