Package org.redisson.spring.transaction

Class ReactiveRedissonTransactionManager

  • All Implemented Interfaces:
    , org.springframework.transaction.ReactiveTransactionManager, org.springframework.transaction.TransactionManager
    public class ReactiveRedissonTransactionManager
extends org.springframework.transaction.reactive.AbstractReactiveTransactionManager
    Author:
    Nikita Koksharov
    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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected reactor.core.publisher.Mono<> doBegin​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,  transaction, org.springframework.transaction.TransactionDefinition definition)  
      protected reactor.core.publisher.Mono<> doCleanupAfterCompletion​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,  transaction)  
      protected reactor.core.publisher.Mono<> doCommit​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction status)  
      protected doGetTransaction​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager)  
      protected reactor.core.publisher.Mono<> doResume​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,  transaction,  suspendedResources)  
      protected reactor.core.publisher.Mono<> doRollback​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction status)  
      protected reactor.core.publisher.Mono<> doSetRollbackOnly​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction status)  
      protected reactor.core.publisher.Mono<> doSuspend​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,  transaction)  
      reactor.core.publisher.Mono<RTransactionReactive> getCurrentTransaction()  
      protected boolean  transaction)  

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

        commit, getReactiveTransaction, prepareForCommit, registerAfterCompletionWithExistingTransaction, rollback

      • Methods inherited from class java.lang.

        , , , , , , , , , ,

    • Constructor Detail

      • ReactiveRedissonTransactionManager

        public ReactiveRedissonTransactionManager​(RedissonReactiveClient redissonClient)

    • Method Detail

      • getCurrentTransaction

        public reactor.core.publisher.Mono<RTransactionReactive> getCurrentTransaction()

      • doGetTransaction

        protected  doGetTransaction​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager)
                           throws org.springframework.transaction.TransactionException
        Specified by:
        doGetTransaction in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doBegin

        protected reactor.core.publisher.Mono<> doBegin​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                     transaction,
                                                    org.springframework.transaction.TransactionDefinition definition)
                                             throws org.springframework.transaction.TransactionException
        Specified by:
        doBegin in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doCommit

        protected reactor.core.publisher.Mono<> doCommit​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                     org.springframework.transaction.reactive.GenericReactiveTransaction status)
                                              throws org.springframework.transaction.TransactionException
        Specified by:
        doCommit in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doRollback

        protected reactor.core.publisher.Mono<> doRollback​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                       org.springframework.transaction.reactive.GenericReactiveTransaction status)
                                                throws org.springframework.transaction.TransactionException
        Specified by:
        doRollback in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doSuspend

        protected reactor.core.publisher.Mono<> doSuspend​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                         transaction)
                                                 throws org.springframework.transaction.TransactionException
        Overrides:
        doSuspend in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doResume

        protected reactor.core.publisher.Mono<> doResume​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                      transaction,
                                                      suspendedResources)
                                              throws org.springframework.transaction.TransactionException
        Overrides:
        doResume in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doSetRollbackOnly

        protected reactor.core.publisher.Mono<> doSetRollbackOnly​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                              org.springframework.transaction.reactive.GenericReactiveTransaction status)
                                                       throws org.springframework.transaction.TransactionException
        Overrides:
        doSetRollbackOnly in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException

      • doCleanupAfterCompletion

        protected reactor.core.publisher.Mono<> doCleanupAfterCompletion​(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                                      transaction)
        Overrides:
        doCleanupAfterCompletion in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

      • isExistingTransaction

        protected boolean isExistingTransaction​( transaction)
                                 throws org.springframework.transaction.TransactionException
        Overrides:
        isExistingTransaction in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
        Throws:
        org.springframework.transaction.TransactionException