@Test public void testGetLocalRegisteredRoutedActionEmptyBuckets() { final Set<String> localRegisteredRoutedAction = mxBean.getLocalRegisteredAction(); Assert.assertNotNull(localRegisteredRoutedAction); Assert.assertTrue(localRegisteredRoutedAction.isEmpty()); }
@Override public Set<String> getLocalRegisteredAction() { ActionRoutingTable table = localData(); Set<String> routedAction = new HashSet<>(table.getItems().size()); for (DOMActionInstance route : table.getItems()) { final YangInstanceIdentifier actionPath = YangInstanceIdentifier.create(new NodeIdentifier( route.getType().lastNodeIdentifier())); if (!actionPath.isEmpty()) { routedAction.add(ROUTE_CONSTANT + actionPath + NAME_CONSTANT + route.getType()); } } log.debug("Locally registered routed RPCs {}", routedAction); return routedAction; }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Set<String> getLocalRegisteredAction() { ActionRoutingTable table = localData(); Set<String> routedAction = new HashSet<>(table.getItems().size()); for (DOMActionInstance route : table.getItems()) { final YangInstanceIdentifier actionPath = YangInstanceIdentifier.create(new NodeIdentifier( route.getType().lastNodeIdentifier())); if (!actionPath.isEmpty()) { routedAction.add(ROUTE_CONSTANT + actionPath + NAME_CONSTANT + route.getType()); } } log.debug("Locally registered routed RPCs {}", routedAction); return routedAction; } }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Set<String> getLocalRegisteredAction() { ActionRoutingTable table = localData(); Set<String> routedAction = new HashSet<>(table.getItems().size()); for (DOMActionInstance route : table.getItems()) { final YangInstanceIdentifier actionPath = YangInstanceIdentifier.create(new NodeIdentifier( route.getType().lastNodeIdentifier())); if (!actionPath.isEmpty()) { routedAction.add(ROUTE_CONSTANT + actionPath + NAME_CONSTANT + route.getType()); } } log.debug("Locally registered routed RPCs {}", routedAction); return routedAction; } RemoteActionRegistryMXBeanImpl(final BucketStoreAccess actionRegistryAccess, final Timeout timeout); }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Set<String> getLocalRegisteredAction() { ActionRoutingTable table = localData(); Set<String> routedAction = new HashSet<>(table.getItems().size()); for (DOMActionInstance route : table.getItems()) { final YangInstanceIdentifier actionPath = YangInstanceIdentifier.create(new NodeIdentifier( route.getType().lastNodeIdentifier())); if (!actionPath.isEmpty()) { routedAction.add(ROUTE_CONSTANT + actionPath + NAME_CONSTANT + route.getType()); } } log.debug("Locally registered routed RPCs {}", routedAction); return routedAction; } RemoteActionRegistryMXBeanImpl(final BucketStoreAccess actionRegistryAccess, final Timeout timeout); @Override Set<String> getLocalRegisteredAction(); @Override Map<String, String> findActionByName(final String name); @Override Map<String, String> findActionByRoute(final String routeId); @Override String getBucketVersions(); }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Set<String> getLocalRegisteredAction() { ActionRoutingTable table = localData(); Set<String> routedAction = new HashSet<>(table.getItems().size()); for (DOMActionInstance route : table.getItems()) { final YangInstanceIdentifier actionPath = YangInstanceIdentifier.create(new NodeIdentifier( route.getType().lastNodeIdentifier())); if (!actionPath.isEmpty()) { routedAction.add(ROUTE_CONSTANT + actionPath + NAME_CONSTANT + route.getType()); } } log.debug("Locally registered routed RPCs {}", routedAction); return routedAction; } RemoteActionRegistryMXBeanImpl(final BucketStoreAccess actionRegistryAccess, final Timeout timeout); @Override Set<String> getLocalRegisteredAction(); @Override Map<String, String> findActionByName(final String name); @Override Map<String, String> findActionByRoute(final String routeId); @Override String getBucketVersions();  }