Package org.springframework.data.mongodb

Class ReactiveMongoTransactionManager.ReactiveMongoTransactionObject

java.lang.Object

org.springframework.data.mongodb.ReactiveMongoTransactionManager.ReactiveMongoTransactionObject

All Implemented Interfaces:

Flushable, org.springframework.transaction.support.SmartTransactionObject

Enclosing class:

ReactiveMongoTransactionManager

protected static class ReactiveMongoTransactionManager.ReactiveMongoTransactionObject
extends Object
implements org.springframework.transaction.support.SmartTransactionObject

MongoDB specific transaction object, representing a MongoResourceHolder. Used as transaction object by ReactiveMongoTransactionManager.

Since:

2.2

Author:

Christoph Strobl, Mark Paluch

See Also:

• ReactiveMongoResourceHolder

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Void>	abortTransaction()	Rollback (abort) the transaction.
reactor.core.publisher.Mono<Void>	commitTransaction()	Commit the transaction.
void	flush()
com.mongodb.reactivestreams.client.ClientSession	getSession()
boolean	isRollbackOnly()

Methods inherited from class java.lang.Object

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

Method Details

commitTransaction

public reactor.core.publisher.Mono<Void> commitTransaction()

Commit the transaction.

abortTransaction

public reactor.core.publisher.Mono<Void> abortTransaction()

Rollback (abort) the transaction.

getSession

@Nullable
public com.mongodb.reactivestreams.client.ClientSession getSession()

isRollbackOnly

public boolean isRollbackOnly()

Specified by:

isRollbackOnly in interface org.springframework.transaction.support.SmartTransactionObject

flush

public void flush()

Specified by:

flush in interface Flushable

Specified by:

flush in interface org.springframework.transaction.support.SmartTransactionObject