Package org.redisson.spring.transaction

Class ReactiveRedissonTransactionManager

  • All Implemented Interfaces:
    Serializable, 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<Void> doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction, org.springframework.transaction.TransactionDefinition definition)  
      protected reactor.core.publisher.Mono<Void> doCleanupAfterCompletion(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction)  
      protected reactor.core.publisher.Mono<Void> doCommit(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction status)  
      protected Object doGetTransaction(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager)  
      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 synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction status)  
      protected reactor.core.publisher.Mono<Void> doSetRollbackOnly(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction status)  
      protected reactor.core.publisher.Mono<Object> doSuspend(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transaction)  
      reactor.core.publisher.Mono<RTransactionReactive> getCurrentTransaction()  
      protected boolean isExistingTransaction(Object transaction)  

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

        commit, getReactiveTransaction, prepareForCommit, registerAfterCompletionWithExistingTransaction, rollback

    • Constructor Detail

      • ReactiveRedissonTransactionManager

        public ReactiveRedissonTransactionManager(RedissonReactiveClient redissonClient)

    • Method Detail

      • getCurrentTransaction

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

      • doGetTransaction

        protected Object 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<Void> doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                    Object 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<Void> 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<Void> 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<Object> doSuspend(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                        Object 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<Void> doResume(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                     Object transaction,
                                                     Object 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<Void> 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<Void> doCleanupAfterCompletion(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager,
                                                                     Object transaction)
        Overrides:
        doCleanupAfterCompletion in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager

      • isExistingTransaction

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