- super("RemoteRpcRegistry", "RemoteRpcBroker", null);
- this.rpcRegistryAccess = rpcRegistryAccess;
- this.timeout = timeout;
- registerMBean();
- }
-
- @SuppressWarnings({"unchecked", "checkstyle:IllegalCatch", "rawtypes"})
- private RoutingTable getLocalData() {
- try {
- return (RoutingTable) Await.result((Future) rpcRegistryAccess.getLocalData(), timeout.duration());
- } catch (Exception e) {
- throw new RuntimeException("getLocalData failed", e);
- }
- }
-
- @SuppressWarnings({"unchecked", "checkstyle:IllegalCatch", "rawtypes"})
- private Map<Address, Bucket<RoutingTable>> getRemoteBuckets() {
- try {
- return (Map<Address, Bucket<RoutingTable>>) Await.result((Future)rpcRegistryAccess.getRemoteBuckets(),
- timeout.duration());
- } catch (Exception e) {
- throw new RuntimeException("getRemoteBuckets failed", e);
- }
+ super("RemoteRpcRegistry", "RemoteRpcBroker", rpcRegistryAccess, timeout);