@Test public void testGetBucketVersions() { testActor.tell(new RpcRegistry.Messages.AddOrUpdateRoutes(Lists.newArrayList(buckets)), ActorRef.noSender()); final String bucketVersions = mxBean.getBucketVersions(); assertTrue(bucketVersions.contains(testActor.provider().getDefaultAddress().toString())); }
@Override public String getBucketVersions() { return bucketVersions(); }
RemoteRpcRegistryMXBeanImpl extends AbstractRegistryMXBean<RoutingTable, DOMRpcIdentifier> implements RemoteRpcRegistryMXBean { @Override public String getBucketVersions() { return bucketVersions(); } }
RemoteRpcRegistryMXBeanImpl extends AbstractRegistryMXBean<RoutingTable, DOMRpcIdentifier> implements RemoteRpcRegistryMXBean { @Override public String getBucketVersions() { return bucketVersions(); } RemoteRpcRegistryMXBeanImpl(final BucketStoreAccess rpcRegistryAccess, final Timeout timeout); }
RemoteRpcRegistryMXBeanImpl extends AbstractRegistryMXBean<RoutingTable, DOMRpcIdentifier> implements RemoteRpcRegistryMXBean { @Override public String getBucketVersions() { return bucketVersions(); } RemoteRpcRegistryMXBeanImpl(final BucketStoreAccess rpcRegistryAccess, final Timeout timeout); @Override Set<String> getGlobalRpc(); @Override Set<String> getLocalRegisteredRoutedRpc(); @Override Map<String, String> findRpcByName(final String name); @Override Map<String, String> findRpcByRoute(final String routeId); @Override String getBucketVersions(); }
RemoteRpcRegistryMXBeanImpl extends AbstractRegistryMXBean<RoutingTable, DOMRpcIdentifier> implements RemoteRpcRegistryMXBean { @Override public String getBucketVersions() { return bucketVersions(); } RemoteRpcRegistryMXBeanImpl(final BucketStoreAccess rpcRegistryAccess, final Timeout timeout); @Override Set<String> getGlobalRpc(); @Override Set<String> getLocalRegisteredRoutedRpc(); @Override Map<String, String> findRpcByName(final String name); @Override Map<String, String> findRpcByRoute(final String routeId); @Override String getBucketVersions();  }