org.springframework.data.neo4j.core.transaction

Class ReactiveNeo4jTransactionManager

java.lang.Object

org.springframework.transaction.reactive.AbstractReactiveTransactionManager

org.springframework.data.neo4j.core.transaction.ReactiveNeo4jTransactionManager

All Implemented Interfaces:

Serializable, ReactiveTransactionManager, TransactionManager

@API(status=STABLE,
     since="6.0")
public class ReactiveNeo4jTransactionManager
extends org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Since:

6.0

Author:

Gerrit Meier, Michael J. Simons

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

org.springframework.transaction.reactive.AbstractReactiveTransactionManager.SuspendedResourcesHolder

Field Summary

Fields inherited from class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

logger

Constructor Summary

Constructors

Constructor and Description
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver)
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver, ReactiveDatabaseSelectionProvider databaseSelectionProvider)

Method Summary

Modifier and Type	Method and Description
protected reactor.core.publisher.Mono<Void>	doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, Object transaction, TransactionDefinition transactionDefinition)
protected reactor.core.publisher.Mono<Void>	doCleanupAfterCompletion(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, Object transaction)
protected reactor.core.publisher.Mono<Void>	doCommit(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
protected Object	doGetTransaction(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager)
protected reactor.core.publisher.Mono<Void>	doResume(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction, Object suspendedResources)
protected reactor.core.publisher.Mono<Void>	doRollback(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
protected reactor.core.publisher.Mono<Void>	doSetRollbackOnly(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
protected reactor.core.publisher.Mono<Object>	doSuspend(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction)
protected boolean	isExistingTransaction(Object transaction)
static reactor.core.publisher.Mono<org.neo4j.driver.reactive.RxTransaction>	retrieveReactiveTransaction(org.neo4j.driver.Driver driver, String targetDatabase)

Methods inherited from class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

commit, getReactiveTransaction, prepareForCommit, registerAfterCompletionWithExistingTransaction, rollback

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveNeo4jTransactionManager

public ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver)

ReactiveNeo4jTransactionManager

public ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver,
                                       ReactiveDatabaseSelectionProvider databaseSelectionProvider)

Method Detail

retrieveReactiveTransaction

public static reactor.core.publisher.Mono<org.neo4j.driver.reactive.RxTransaction> retrieveReactiveTransaction(org.neo4j.driver.Driver driver,
                                                                                                               String targetDatabase)

doGetTransaction

protected Object doGetTransaction(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager)
                           throws TransactionException

Specified by:

doGetTransaction in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

isExistingTransaction

protected boolean isExistingTransaction(Object transaction)
                                 throws TransactionException

Overrides:

isExistingTransaction in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

doBegin

protected reactor.core.publisher.Mono<Void> doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager,
                                                    Object transaction,
                                                    TransactionDefinition transactionDefinition)
                                             throws TransactionException

Specified by:

doBegin in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

doCleanupAfterCompletion

protected reactor.core.publisher.Mono<Void> doCleanupAfterCompletion(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager,
                                                                     Object transaction)

Overrides:

doCleanupAfterCompletion in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

doCommit

protected reactor.core.publisher.Mono<Void> doCommit(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager,
                                                     org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
                                              throws TransactionException

Specified by:

doCommit in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

doRollback

protected reactor.core.publisher.Mono<Void> doRollback(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager,
                                                       org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
                                                throws TransactionException

Specified by:

doRollback in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

doSuspend

protected reactor.core.publisher.Mono<Object> doSuspend(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                        Object transaction)
                                                 throws TransactionException

Overrides:

doSuspend in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

doResume

protected reactor.core.publisher.Mono<Void> doResume(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                     Object transaction,
                                                     Object suspendedResources)
                                              throws TransactionException

Overrides:

doResume in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException

doSetRollbackOnly

protected reactor.core.publisher.Mono<Void> doSetRollbackOnly(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                              org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
                                                       throws TransactionException

Overrides:

doSetRollbackOnly in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

Throws:

TransactionException