+ actorRef.tell(removeBucketMessage(addr), ActorRef.noSender());
+ }
+
+ @SuppressWarnings({ "unchecked", "rawtypes" })
+ public <T extends BucketData<T>> Future<T> getLocalData() {
+ return (Future) Patterns.ask(actorRef, getLocalDataMessage(), timeout);
+ }
+
+ @SuppressWarnings({ "unchecked", "rawtypes" })
+ public <T extends BucketData<T>> Future<Map<Address, Bucket<T>>> getRemoteBuckets() {
+ return (Future) Patterns.ask(actorRef, getRemoteBucketsMessage(), timeout);