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();  }
@Test public void testGetLocalRegisteredRoutedActionEmptyBuckets() { final Set<String> localRegisteredRoutedAction = mxBean.getLocalRegisteredAction(); Assert.assertNotNull(localRegisteredRoutedAction); Assert.assertTrue(localRegisteredRoutedAction.isEmpty()); }
@Test public void testGetLocalRegisteredRoutedAction() { testActor.tell(new ActionRegistry.Messages.UpdateActions(Lists.newArrayList(buckets), Collections.emptyList()), ActorRef.noSender()); final Set<String> localRegisteredRoutedAction = mxBean.getLocalRegisteredAction(); Assert.assertNotNull(localRegisteredRoutedAction); Assert.assertEquals(1, localRegisteredRoutedAction.size()); final String localAction = localRegisteredRoutedAction.iterator().next(); Assert.assertTrue(localAction.contains(LOCAL_QNAME.toString())); Assert.assertTrue(localAction.contains(LOCAL_SCHEMA_PATH.toString())); }