@API(status=STABLE, since="6.0") public final class ReactiveNeo4jTransactionManager extends AbstractReactiveTransactionManager implements ApplicationContextAware
AbstractReactiveTransactionManager.SuspendedResourcesHolder
logger
Constructor and Description |
---|
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver)
This will create a transaction manager for the default database.
|
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver,
ReactiveDatabaseSelectionProvider databaseSelectionProvider)
This will create a transaction manager targeting whatever the database selection provider determines.
|
ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver,
ReactiveDatabaseSelectionProvider databaseSelectionProvider,
Neo4jBookmarkManager bookmarkManager)
This constructor can be used to configure the bookmark manager being used.
|
Modifier and Type | Method and Description |
---|---|
protected reactor.core.publisher.Mono<Void> |
doBegin(TransactionSynchronizationManager transactionSynchronizationManager,
Object transaction,
TransactionDefinition transactionDefinition) |
protected reactor.core.publisher.Mono<Void> |
doCleanupAfterCompletion(TransactionSynchronizationManager transactionSynchronizationManager,
Object transaction) |
protected reactor.core.publisher.Mono<Void> |
doCommit(TransactionSynchronizationManager transactionSynchronizationManager,
GenericReactiveTransaction genericReactiveTransaction) |
protected Object |
doGetTransaction(TransactionSynchronizationManager transactionSynchronizationManager) |
protected reactor.core.publisher.Mono<Void> |
doResume(TransactionSynchronizationManager synchronizationManager,
Object transaction,
Object suspendedResources) |
protected reactor.core.publisher.Mono<Void> |
doRollback(TransactionSynchronizationManager transactionSynchronizationManager,
GenericReactiveTransaction genericReactiveTransaction) |
protected reactor.core.publisher.Mono<Void> |
doSetRollbackOnly(TransactionSynchronizationManager synchronizationManager,
GenericReactiveTransaction genericReactiveTransaction) |
protected reactor.core.publisher.Mono<Object> |
doSuspend(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) |
void |
setApplicationContext(ApplicationContext applicationContext) |
commit, getReactiveTransaction, prepareForCommit, registerAfterCompletionWithExistingTransaction, rollback
public ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver)
driver
- A driver instancepublic ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver, ReactiveDatabaseSelectionProvider databaseSelectionProvider)
driver
- A driver instancedatabaseSelectionProvider
- The database selection provider to determine the database in which the transactions should happenpublic ReactiveNeo4jTransactionManager(org.neo4j.driver.Driver driver, ReactiveDatabaseSelectionProvider databaseSelectionProvider, Neo4jBookmarkManager bookmarkManager)
driver
- A driver instancedatabaseSelectionProvider
- The database selection provider to determine the database in which the transactions should happenbookmarkManager
- A bookmark managerpublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext
in interface ApplicationContextAware
BeansException
public static reactor.core.publisher.Mono<org.neo4j.driver.reactive.RxTransaction> retrieveReactiveTransaction(org.neo4j.driver.Driver driver, @Nullable String targetDatabase)
protected Object doGetTransaction(TransactionSynchronizationManager transactionSynchronizationManager) throws TransactionException
doGetTransaction
in class AbstractReactiveTransactionManager
TransactionException
protected boolean isExistingTransaction(Object transaction) throws TransactionException
isExistingTransaction
in class AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doBegin(TransactionSynchronizationManager transactionSynchronizationManager, Object transaction, TransactionDefinition transactionDefinition) throws TransactionException
doBegin
in class AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doCleanupAfterCompletion(TransactionSynchronizationManager transactionSynchronizationManager, Object transaction)
doCleanupAfterCompletion
in class AbstractReactiveTransactionManager
protected reactor.core.publisher.Mono<Void> doCommit(TransactionSynchronizationManager transactionSynchronizationManager, GenericReactiveTransaction genericReactiveTransaction) throws TransactionException
doCommit
in class AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doRollback(TransactionSynchronizationManager transactionSynchronizationManager, GenericReactiveTransaction genericReactiveTransaction) throws TransactionException
doRollback
in class AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Object> doSuspend(TransactionSynchronizationManager synchronizationManager, Object transaction) throws TransactionException
doSuspend
in class AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doResume(TransactionSynchronizationManager synchronizationManager, Object transaction, Object suspendedResources) throws TransactionException
doResume
in class AbstractReactiveTransactionManager
TransactionException
protected reactor.core.publisher.Mono<Void> doSetRollbackOnly(TransactionSynchronizationManager synchronizationManager, GenericReactiveTransaction genericReactiveTransaction) throws TransactionException
doSetRollbackOnly
in class AbstractReactiveTransactionManager
TransactionException
Copyright © 2019–2021 Neo4j, Neo4j Sweden AB. All rights reserved.