X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FAbstractActorTest.java;h=e23a76b0b223ee2b8ee0d5398da878cd520caf65;hp=45ef32f7ad798ad15a0840c1c7860bf61f34913d;hb=5a9287bb6ddaaa8805939b3b3301f648c03785f4;hpb=e22159a0e53bf93a94908e2c3988ceeba9ed8183 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/AbstractActorTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/AbstractActorTest.java index 45ef32f7ad..e23a76b0b2 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/AbstractActorTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/AbstractActorTest.java @@ -10,25 +10,42 @@ package org.opendaylight.controller.cluster.datastore; import akka.actor.ActorSystem; import akka.testkit.JavaTestKit; +import org.apache.commons.io.FileUtils; import org.junit.AfterClass; import org.junit.BeforeClass; +import java.io.File; +import java.io.IOException; + public abstract class AbstractActorTest { - private static ActorSystem system; - - @BeforeClass - public static void setUpClass(){ - system = ActorSystem.create("test"); - } - - @AfterClass - public static void tearDownClass(){ - JavaTestKit.shutdownActorSystem(system); - system = null; - } - - protected ActorSystem getSystem(){ - return system; - } + private static ActorSystem system; + + @BeforeClass + public static void setUpClass() throws IOException { + File journal = new File("journal"); + + if(journal.exists()) { + FileUtils.deleteDirectory(journal); + } + + System.setProperty("shard.persistent", "false"); + system = ActorSystem.create("test"); + } + + @AfterClass + public static void tearDownClass() throws IOException { + JavaTestKit.shutdownActorSystem(system); + system = null; + + File journal = new File("journal"); + + if(journal.exists()) { + FileUtils.deleteDirectory(journal); + } + } + + protected ActorSystem getSystem() { + return system; + } }