+ @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);
+ }
+ }
+