CAMEL-8841: camel:context-inflight returns 'Object name cannot be null'. Thanks to Martin Lichtin for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cca30b2f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cca30b2f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cca30b2f Branch: refs/heads/camel-2.15.x Commit: cca30b2f2b5ea5ef1b51bb6bc68e2d8f4d13766b Parents: 6384121 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Jun 15 13:17:21 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Jun 15 13:17:40 2015 +0200 ---------------------------------------------------------------------- .../apache/camel/commands/AbstractLocalCamelController.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/cca30b2f/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/AbstractLocalCamelController.java ---------------------------------------------------------------------- diff --git a/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/AbstractLocalCamelController.java b/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/AbstractLocalCamelController.java index 1a08445..418013c 100644 --- a/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/AbstractLocalCamelController.java +++ b/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/AbstractLocalCamelController.java @@ -178,11 +178,7 @@ public abstract class AbstractLocalCamelController extends AbstractCamelControll ManagementAgent agent = context.getManagementStrategy().getManagementAgent(); if (agent != null) { MBeanServer mBeanServer = agent.getMBeanServer(); - ObjectName on = null; - Set<ObjectName> set = mBeanServer.queryNames(new ObjectName(agent.getMBeanObjectDomainName() + ":type=services,name=DefaultInflightRepository,*"), null); - if (set.size() == 1) { - on = set.iterator().next(); - } + ObjectName on = new ObjectName(agent.getMBeanObjectDomainName() + ":type=services,name=DefaultInflightRepository,context=" + context.getManagementName()); if (mBeanServer.isRegistered(on)) { TabularData list = (TabularData) mBeanServer.invoke(on, "browse", new Object[]{limit, sortByLongestDuration}, new String[]{"int", "boolean"}); Collection<CompositeData> values = (Collection<CompositeData>) list.values();
