import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
+
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
}
+ @SuppressWarnings("resource")
@Test
public void testConstructor(){
ActorSystem actorSystem = mock(ActorSystem.class);
new DistributedDataStore(actorSystem, "config",
- mock(ClusterWrapper.class), mock(Configuration.class));
+ mock(ClusterWrapper.class), mock(Configuration.class),
+ new DatastoreContext());
verify(actorSystem).actorOf(any(Props.class), eq("shardmanager-config"));
}