* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.controller.cluster.datastore;
import akka.actor.ActorRef;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.Executor;
-import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
+import org.eclipse.jdt.annotation.NonNull;
+import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor;
import org.opendaylight.mdsal.common.api.PostCanCommitStep;
}, MoreExecutors.directExecutor());
}
- @Nullable
- abstract CohortBehaviour<?, ?> nextBehaviour(TransactionIdentifier txId, S nextStep);
+ abstract @Nullable CohortBehaviour<?, ?> nextBehaviour(TransactionIdentifier txId, S nextStep);
- @Nonnull
- abstract ListenableFuture<S> process(M command);
+ abstract @NonNull ListenableFuture<S> process(M command);
abstract ListenableFuture<?> abort();
@Override
ListenableFuture<PostCanCommitStep> process(CanCommit message) {
- return cohort.canCommit(message.getTxId(), message.getCandidates(), message.getSchema());
+ return cohort.canCommit(message.getTxId(), message.getSchema(), message.getCandidates());
}
@Override