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.

Author:

Dmitry Solomakha

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

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

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