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