X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-segmented-journal%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fakka%2Fsegjournal%2FDataJournalV0.java;fp=opendaylight%2Fmd-sal%2Fsal-akka-segmented-journal%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fakka%2Fsegjournal%2FDataJournalV0.java;h=5eb688a6150ac1248a119090e7b9e8c4034619ff;hb=a6a5fe176855c600d957dad4bf0dd74dbcf24a55;hp=93c93f8acc776e10f1de5b24c746426a0ed28801;hpb=f8208948eb67a26207343ca60b5b19286f5e4410;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-segmented-journal/src/main/java/org/opendaylight/controller/akka/segjournal/DataJournalV0.java b/opendaylight/md-sal/sal-akka-segmented-journal/src/main/java/org/opendaylight/controller/akka/segjournal/DataJournalV0.java index 93c93f8acc..5eb688a615 100644 --- a/opendaylight/md-sal/sal-akka-segmented-journal/src/main/java/org/opendaylight/controller/akka/segjournal/DataJournalV0.java +++ b/opendaylight/md-sal/sal-akka-segmented-journal/src/main/java/org/opendaylight/controller/akka/segjournal/DataJournalV0.java @@ -14,11 +14,11 @@ import akka.persistence.AtomicWrite; import akka.persistence.PersistentRepr; import com.codahale.metrics.Histogram; import io.atomix.storage.journal.Indexed; +import io.atomix.storage.journal.JournalSerdes; import io.atomix.storage.journal.SegmentedJournal; import io.atomix.storage.journal.SegmentedJournalReader; import io.atomix.storage.journal.SegmentedJournalWriter; import io.atomix.storage.journal.StorageLevel; -import io.atomix.utils.serializer.Namespace; import java.io.File; import java.io.Serializable; import java.util.List; @@ -45,7 +45,7 @@ final class DataJournalV0 extends DataJournal { super(persistenceId, messageSize); entries = SegmentedJournal.builder() .withStorageLevel(storage).withDirectory(directory).withName("data") - .withNamespace(Namespace.builder() + .withNamespace(JournalSerdes.builder() .register(new DataJournalEntrySerializer(system), FromPersistence.class, ToPersistence.class) .build()) .withMaxEntrySize(maxEntrySize).withMaxSegmentSize(maxSegmentSize)