import akka.persistence.Persistence;
import akka.persistence.SelectedSnapshot;
import akka.persistence.SnapshotMetadata;
-import akka.testkit.JavaTestKit;
import akka.testkit.TestProbe;
+import akka.testkit.javadsl.TestKit;
import java.lang.reflect.Field;
import java.util.Optional;
import java.util.concurrent.TimeUnit;
@After
public void tearDown() throws Exception {
- JavaTestKit.shutdownActorSystem(system);
+ TestKit.shutdownActorSystem(system);
}
@Test
private static class MockedActor extends AbstractClientActor {
private final ClientActorBehavior<?> initialBehavior;
+ private final ClientActorConfig mockConfig = AccessClientUtil.newMockClientActorConfig();
private static Props props(final FrontendIdentifier frontendId, final ClientActorBehavior<?> initialBehavior) {
return Props.create(MockedActor.class, () -> new MockedActor(frontendId, initialBehavior));
}
- private MockedActor(final FrontendIdentifier frontendId, final ClientActorBehavior<?> initialBehavior) {
+ MockedActor(final FrontendIdentifier frontendId, final ClientActorBehavior<?> initialBehavior) {
super(frontendId);
this.initialBehavior = initialBehavior;
}
@Override
protected ClientActorConfig getClientActorConfig() {
- return new ClientActorConfig() {
- @Override
- public String getTempFileDirectory() {
- return null;
- }
-
- @Override
- public int getMaximumMessageSliceSize() {
- return 2000000;
- }
-
- @Override
- public int getFileBackedStreamingThreshold() {
- return 1000000000;
- }
- };
+ return mockConfig;
}
}