import com.google.common.util.concurrent.FluentFuture;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.MoreExecutors;
-import javax.annotation.CheckReturnValue;
import org.eclipse.jdt.annotation.NonNull;
+import org.opendaylight.controller.md.sal.common.api.MappingCheckedFuture;
import org.opendaylight.mdsal.common.api.CommitInfo;
-import org.opendaylight.mdsal.common.api.MappingCheckedFuture;
import org.opendaylight.yangtools.concepts.Path;
import org.opendaylight.yangtools.util.concurrent.ExceptionMapper;
* @deprecated Use {@link #commit()} instead.
*/
@Deprecated
- @CheckReturnValue
default CheckedFuture<Void, TransactionCommitFailedException> submit() {
return MappingCheckedFuture.create(commit().transform(ignored -> null, MoreExecutors.directExecutor()),
SUBMIT_EXCEPTION_MAPPER);
* {@link TransactionCommitFailedException} or an exception derived from TransactionCommitFailedException.
* @throws IllegalStateException if the transaction is already committed or was canceled.
*/
- @CheckReturnValue
@NonNull FluentFuture<? extends @NonNull CommitInfo> commit();
/**
ExceptionMapper<TransactionCommitFailedException> SUBMIT_EXCEPTION_MAPPER =
new ExceptionMapper<TransactionCommitFailedException>("submit", TransactionCommitFailedException.class) {
@Override
- protected TransactionCommitFailedException newWithCause(String message, Throwable cause) {
+ protected TransactionCommitFailedException newWithCause(final String message, final Throwable cause) {
return new TransactionCommitFailedException(message, cause);
}
};