@API(status=STABLE, since="6.0") public class ReactiveNeo4jTransactionManager extends org.springframework.transaction.reactive.AbstractReactiveTransactionManager
org.springframework.transaction.reactive.AbstractReactiveTransactionManager.SuspendedResourcesHolder
logger
Constructor and Description |
---|
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver) |
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver,
ReactiveDatabaseSelectionProvider databaseSelectionProvider) |
commit, getReactiveTransaction, prepareForCommit, registerAfterCompletionWithExistingTransaction, rollback
public ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver)
public ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver, ReactiveDatabaseSelectionProvider databaseSelectionProvider)
public static reactor.core.publisher.Mono<org.neo4j.driver.reactive.RxTransaction> retrieveReactiveTransaction(org.neo4j.driver.Driver driver, String targetDatabase)
protected Object doGetTransaction(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager) throws TransactionException
doGetTransaction
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
protected boolean isExistingTransaction(Object transaction) throws TransactionException
isExistingTransaction
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, Object transaction, TransactionDefinition transactionDefinition) throws TransactionException
doBegin
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
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) throws TransactionException
doCommit
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doRollback(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction) throws TransactionException
doRollback
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Object> doSuspend(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction) throws TransactionException
doSuspend
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doResume(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction, Object suspendedResources) throws TransactionException
doResume
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doSetRollbackOnly(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction) throws TransactionException
doSetRollbackOnly
in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
TransactionException
Copyright © 2019–2020 Neo4j, Neo4j Sweden AB. All rights reserved.