ReactiveNeo4jTransactionManager (Spring Data Neo4j 6.0.0-M2 API)

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

All Methods Static Methods Instance Methods Concrete Methods
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

Class ReactiveNeo4jTransactionManager

Nested Class Summary

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

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Constructor Detail

ReactiveNeo4jTransactionManager

ReactiveNeo4jTransactionManager

Method Detail

retrieveReactiveTransaction

doGetTransaction

isExistingTransaction

doBegin

doCleanupAfterCompletion

doCommit

doRollback

doSuspend

doResume

doSetRollbackOnly