import java.util.concurrent.CompletionStage;
import javax.annotation.concurrent.ThreadSafe;
import org.opendaylight.controller.cluster.access.client.BackendInfoResolver;
import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
import java.util.concurrent.CompletionStage;
import javax.annotation.concurrent.ThreadSafe;
import org.opendaylight.controller.cluster.access.client.BackendInfoResolver;
import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
private volatile ShardState state;
// FIXME: we really need just ActorContext.findPrimaryShardAsync()
private volatile ShardState state;
// FIXME: we really need just ActorContext.findPrimaryShardAsync()
- super(clientId, actorContext);
- this.shardName = Preconditions.checkNotNull(shardName);
+ super(clientId, actorUtils);
+ this.shardName = requireNonNull(shardName);