@Test public void testFindActionByRouteEmptyBuckets() { final Map<String, String> rpcByRoute = mxBean.findActionByRoute(""); Assert.assertNotNull(rpcByRoute); Assert.assertTrue(rpcByRoute.isEmpty()); }
@Override public Map<String, String> findActionByRoute(final String routeId) { ActionRoutingTable localTable = localData(); Map<String, String> rpcMap = new HashMap<>(getActionMemberMapByAction(localTable, routeId, LOCAL_CONSTANT)); Map<Address, Bucket<ActionRoutingTable>> buckets = remoteBuckets(); for (Map.Entry<Address, Bucket<ActionRoutingTable>> entry : buckets.entrySet()) { ActionRoutingTable table = entry.getValue().getData(); rpcMap.putAll(getActionMemberMapByAction(table, routeId, entry.getKey().toString())); } log.debug("list of Actions {} searched by route {}", rpcMap, routeId); return rpcMap; }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Map<String, String> findActionByRoute(final String routeId) { ActionRoutingTable localTable = localData(); Map<String, String> rpcMap = new HashMap<>(getActionMemberMapByAction(localTable, routeId, LOCAL_CONSTANT)); Map<Address, Bucket<ActionRoutingTable>> buckets = remoteBuckets(); for (Map.Entry<Address, Bucket<ActionRoutingTable>> entry : buckets.entrySet()) { ActionRoutingTable table = entry.getValue().getData(); rpcMap.putAll(getActionMemberMapByAction(table, routeId, entry.getKey().toString())); } log.debug("list of Actions {} searched by route {}", rpcMap, routeId); return rpcMap; } }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Map<String, String> findActionByRoute(final String routeId) { ActionRoutingTable localTable = localData(); Map<String, String> rpcMap = new HashMap<>(getActionMemberMapByAction(localTable, routeId, LOCAL_CONSTANT)); Map<Address, Bucket<ActionRoutingTable>> buckets = remoteBuckets(); for (Map.Entry<Address, Bucket<ActionRoutingTable>> entry : buckets.entrySet()) { ActionRoutingTable table = entry.getValue().getData(); rpcMap.putAll(getActionMemberMapByAction(table, routeId, entry.getKey().toString())); } log.debug("list of Actions {} searched by route {}", rpcMap, routeId); return rpcMap; } RemoteActionRegistryMXBeanImpl(final BucketStoreAccess actionRegistryAccess, final Timeout timeout); }
RemoteActionRegistryMXBeanImpl extends AbstractRegistryMXBean<ActionRoutingTable, DOMActionInstance> implements RemoteActionRegistryMXBean { @Override public Map<String, String> findActionByRoute(final String routeId) { ActionRoutingTable localTable = localData(); Map<String, String> rpcMap = new HashMap<>(getActionMemberMapByAction(localTable, routeId, LOCAL_CONSTANT)); Map<Address, Bucket<ActionRoutingTable>> buckets = remoteBuckets(); for (Map.Entry<Address, Bucket<ActionRoutingTable>> entry : buckets.entrySet()) { ActionRoutingTable table = entry.getValue().getData(); rpcMap.putAll(getActionMemberMapByAction(table, routeId, entry.getKey().toString())); } log.debug("list of Actions {} searched by route {}", rpcMap, routeId); return rpcMap; } 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 Map<String, String> findActionByRoute(final String routeId) { ActionRoutingTable localTable = localData(); Map<String, String> rpcMap = new HashMap<>(getActionMemberMapByAction(localTable, routeId, LOCAL_CONSTANT)); Map<Address, Bucket<ActionRoutingTable>> buckets = remoteBuckets(); for (Map.Entry<Address, Bucket<ActionRoutingTable>> entry : buckets.entrySet()) { ActionRoutingTable table = entry.getValue().getData(); rpcMap.putAll(getActionMemberMapByAction(table, routeId, entry.getKey().toString())); } log.debug("list of Actions {} searched by route {}", rpcMap, routeId); return rpcMap; } 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();  }