Separate out {From,To}ByteBufMapper

[controller.git] / opendaylight / md-sal / sal-akka-segmented-journal / src / main / java / org / opendaylight / controller / akka / segjournal / DataJournalV0.java

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 c5f9d7205eb3d9b7886a818c8333e268079372ee..935ded32e27931c423325fd6831958780a0119cc 100644 (file)
--- 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
@@ -41,16 +41,18 @@ final class DataJournalV0 extends DataJournal {
     DataJournalV0(final String persistenceId, final Histogram messageSize, final ActorSystem system,
             final StorageLevel storage, final File directory, final int maxEntrySize, final int maxSegmentSize) {
         super(persistenceId, messageSize);
+
+        final var serdes = JournalSerdes.builder()
+            .register(new DataJournalEntrySerdes(system), FromPersistence.class, ToPersistence.class)
+            .build();
+
         entries = new SegmentedJournal<>(SegmentedByteBufJournal.builder()
             .withDirectory(directory)
             .withName("data")
             .withStorageLevel(storage)
             .withMaxEntrySize(maxEntrySize)
             .withMaxSegmentSize(maxSegmentSize)
-            .build(),
-            JournalSerdes.builder()
-                .register(new DataJournalEntrySerdes(system), FromPersistence.class, ToPersistence.class)
-                .build().toMapper());
+            .build(), serdes.toReadMapper(), serdes.toWriteMapper());
     }
 
     @Override