- 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) {
-
- GossipStatus status = new GossipStatus(selfAddress, localVersions);
- remote.tell(status, getSelf());
- }
-
- void sendGossipStatusTo(final ActorSelection remote, final Map<Address, Long> localVersions) {
-
- GossipStatus status = new GossipStatus(selfAddress, localVersions);
- remote.tell(status, getSelf());