import akka.actor.ActorRef;
import akka.actor.Address;
import akka.actor.Props;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
private final Set<DOMRpcIdentifier> rpcs;
private final ActorRef router;
- RemoteRpcEndpoint(final ActorRef router, final Collection<DOMRpcIdentifier> rpcs) {
+ @VisibleForTesting
+ public RemoteRpcEndpoint(final ActorRef router, final Collection<DOMRpcIdentifier> rpcs) {
this.router = Preconditions.checkNotNull(router);
this.rpcs = ImmutableSet.copyOf(rpcs);
}
public static final class UpdateRemoteEndpoints {
private final Map<Address, Optional<RemoteRpcEndpoint>> endpoints;
- UpdateRemoteEndpoints(final Map<Address, Optional<RemoteRpcEndpoint>> endpoints) {
+ @VisibleForTesting
+ public UpdateRemoteEndpoints(final Map<Address, Optional<RemoteRpcEndpoint>> endpoints) {
this.endpoints = ImmutableMap.copyOf(endpoints);
}