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%2FAbstractThreePhaseCommitCohort.java;h=49b398f3fcd158b513b17b4acba34f05c9a2dcd0;hp=7ef1cd49851ef838361c509e3f8af60020de644b;hb=118cd0216b0c6b0ec1a01689ec2025a13e090861;hpb=73ab61a037dd2489600acbc1eaf6f9ee549c204a diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/AbstractThreePhaseCommitCohort.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/AbstractThreePhaseCommitCohort.java index 7ef1cd4985..49b398f3fc 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/AbstractThreePhaseCommitCohort.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/AbstractThreePhaseCommitCohort.java @@ -10,7 +10,9 @@ package org.opendaylight.controller.cluster.datastore; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import java.util.List; +import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort; +import org.opendaylight.yangtools.yang.common.Empty; import scala.concurrent.Future; /** @@ -19,8 +21,10 @@ import scala.concurrent.Future; * futures. */ public abstract class AbstractThreePhaseCommitCohort implements DOMStoreThreePhaseCommitCohort { - protected static final ListenableFuture IMMEDIATE_VOID_SUCCESS = Futures.immediateFuture(null); - protected static final ListenableFuture IMMEDIATE_BOOLEAN_SUCCESS = Futures.immediateFuture(Boolean.TRUE); + protected static final @NonNull ListenableFuture IMMEDIATE_EMPTY_SUCCESS = + Futures.immediateFuture(Empty.value()); + protected static final @NonNull ListenableFuture IMMEDIATE_BOOLEAN_SUCCESS = + Futures.immediateFuture(Boolean.TRUE); abstract List> getCohortFutures(); }