Package org.springframework.data.couchbase.transaction

Class CouchbaseTransactionalOperator

java.lang.Object

org.springframework.data.couchbase.transaction.CouchbaseTransactionalOperator

All Implemented Interfaces:

TransactionalOperator

public class CouchbaseTransactionalOperator
extends Object
implements TransactionalOperator

The TransactionalOperator interface is another method to perform reactive transactions with Spring.

We recommend instead using a regular reactive SDK transaction, and performing Spring operations inside it.

Author:

Graham Pople

Method Summary

Modifier and Type	Method	Description
static CouchbaseTransactionalOperator	create(CouchbaseCallbackTransactionManager manager)
<T> reactor.core.publisher.Flux<T>	execute(TransactionCallback<T> action)
<T> reactor.core.publisher.Mono<T>	transactional(reactor.core.publisher.Mono<T> mono)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.transaction.reactive.TransactionalOperator

transactional

Method Details

create

public static CouchbaseTransactionalOperator create(CouchbaseCallbackTransactionManager manager)

transactional

public <T> reactor.core.publisher.Mono<T> transactional(reactor.core.publisher.Mono<T> mono)

Specified by:

transactional in interface TransactionalOperator

execute

public <T> reactor.core.publisher.Flux<T> execute(TransactionCallback<T> action)
                                           throws TransactionException

Specified by:

execute in interface TransactionalOperator

Throws:

TransactionException