- //Find gossiper on remote system
- ActorSelection remoteRef = getContext().system().actorSelection(
- remoteActorSystemAddress.toString() + getSelf().path().toStringWithoutAddress());
-
- LOG.trace("Sending bucket versions to [{}]", remoteRef);
-
- futureReply.map(getMapperToSendLocalStatus(remoteRef), getContext().dispatcher());
- }
-
- /**
- * Helper to send bucket versions received from local store.
- *
- * @param remote remote gossiper to send versions to
- * @param localVersions bucket versions received from local store
- */
- void sendGossipStatusTo(final ActorRef remote, final Map<Address, Long> localVersions) {