Package com.google.cloud.spring.data.firestore.transaction

Class ReactiveFirestoreTransactionManager

java.lang.Object
org.springframework.transaction.reactive.AbstractReactiveTransactionManager
com.google.cloud.spring.data.firestore.transaction.ReactiveFirestoreTransactionManager
All Implemented Interfaces:
Serializable, org.springframework.transaction.ReactiveTransactionManager, org.springframework.transaction.TransactionManager
public class ReactiveFirestoreTransactionManager extends org.springframework.transaction.reactive.AbstractReactiveTransactionManager
Firestore-specific implementation of ReactiveTransactionManager.
See Also:

  • 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
    Description
    ReactiveFirestoreTransactionManager(com.google.firestore.v1.FirestoreGrpc.FirestoreStub firestore, String parent, FirestoreClassMapper classMapper)
    Constructor for ReactiveFirestoreTransactionManager.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected reactor.core.publisher.Mono<Void>
    doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager synchronizationManager, Object transactionObject, org.springframework.transaction.TransactionDefinition transactionDefinition)
     
    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 synchronizationManager)
     
    protected reactor.core.publisher.Mono<Void>
    doRollback(org.springframework.transaction.reactive.TransactionSynchronizationManager transactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction)
     

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

    commit, doCleanupAfterCompletion, doResume, doSetRollbackOnly, doSuspend, getReactiveTransaction, isExistingTransaction, prepareForCommit, registerAfterCompletionWithExistingTransaction, rollback

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ReactiveFirestoreTransactionManager

      public ReactiveFirestoreTransactionManager(com.google.firestore.v1.FirestoreGrpc.FirestoreStub firestore, String parent, FirestoreClassMapper classMapper)
      Constructor for ReactiveFirestoreTransactionManager.
      Parameters:
      firestore - Firestore gRPC stub
      parent - the parent resource. For example: projects/{project_id}/databases/{database_id}/documents or
      classMapper - Firestore class mapper

  • Method Details

    • 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 transactionObject, org.springframework.transaction.TransactionDefinition transactionDefinition) 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 transactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction) 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 transactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction genericReactiveTransaction) throws org.springframework.transaction.TransactionException
      Specified by:
      doRollback in class org.springframework.transaction.reactive.AbstractReactiveTransactionManager
      Throws:
      org.springframework.transaction.TransactionException