X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FShardTransaction.java;h=613b3749e086abc8cdea38fd322872f656235a91;hp=af25df13d2865ba867d6a529d3ad947101b1510a;hb=3927509ec3ecfa32a51b725d2b7155d425f5b877;hpb=3e5bfba47ae5fe04360343073273a141730daefd diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java index af25df13d2..613b3749e0 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java @@ -129,9 +129,9 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering try { final CheckedFuture>, ReadFailedException> future = transaction.read(path); Optional> optional = future.checkedGet(); - ReadDataReply readDataReply = new ReadDataReply(optional.orNull()); + ReadDataReply readDataReply = new ReadDataReply(optional.orNull(), clientTxVersion); - sender().tell((returnSerialized ? readDataReply.toSerializable(clientTxVersion): readDataReply), self()); + sender().tell((returnSerialized ? readDataReply.toSerializable(): readDataReply), self()); } catch (Exception e) { LOG.debug(String.format("Unexpected error reading path %s", path), e);