raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

java format

Browse source
This commit is contained in:
Patrik Nordwall 2020-03-30 16:56:22 +02:00
parent 7e07ee17a6
commit 3c12f19576
1 changed files with 15 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

30
akka-docs/src/test/java/jdocs/persistence/testkit/PersistenceInitTest.java
View file

@ -13,7 +13,7 @@ import org.junit.Test;
import java.util.UUID; import java.util.UUID;
//#imports // #imports
import akka.persistence.testkit.javadsl.PersistenceInit; import akka.persistence.testkit.javadsl.PersistenceInit;
import akka.Done; import akka.Done;
@ -21,28 +21,28 @@ import java.time.Duration;
import java.util.concurrent.CompletionStage; import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
//#imports // #imports
public class PersistenceInitTest extends AbstractJavaTest { public class PersistenceInitTest extends AbstractJavaTest {
@ClassRule @ClassRule
public static final TestKitJunitResource testKit = public static final TestKitJunitResource testKit =
new TestKitJunitResource( new TestKitJunitResource(
ConfigFactory.parseString( ConfigFactory.parseString(
"akka.persistence.journal.plugin = \"akka.persistence.journal.inmem\" \n" "akka.persistence.journal.plugin = \"akka.persistence.journal.inmem\" \n"
+ "akka.persistence.journal.inmem.test-serialization = on \n" + + "akka.persistence.journal.inmem.test-serialization = on \n"
"akka.persistence.snapshot-store.plugin = \"akka.persistence.snapshot-store.local\" \n" + "akka.persistence.snapshot-store.plugin = \"akka.persistence.snapshot-store.local\" \n"
+ "akka.persistence.snapshot-store.local.dir = \"target/snapshot-" + "akka.persistence.snapshot-store.local.dir = \"target/snapshot-"
+ UUID.randomUUID().toString() + UUID.randomUUID().toString()
+ "\" \n" + "\" \n")
) .withFallback(ConfigFactory.defaultApplication()));
.withFallback(ConfigFactory.defaultApplication()));
@Test @Test
public void testInit() throws Exception { public void testInit() throws Exception {
//#init // #init
Duration timeout = Duration.ofSeconds(5); Duration timeout = Duration.ofSeconds(5);
CompletionStage<Done> done = PersistenceInit.initializeDefaultPlugins(testKit.system(), timeout); CompletionStage<Done> done =
PersistenceInit.initializeDefaultPlugins(testKit.system(), timeout);
done.toCompletableFuture().get(timeout.getSeconds(), TimeUnit.SECONDS); done.toCompletableFuture().get(timeout.getSeconds(), TimeUnit.SECONDS);
//#init // #init
} }
} }