Spring Webflux with Transactions

Question

Is it possible to have transaction management using Spring Webflux? We will be building a microservice and I'm considering using Spring Webflux but I'd like to make sure that a PUT/POST request that mutates state can be atomic. For example if the request that is received needs to:

• Update state in the microservice's own database
• Make an update to a downstream service via a REST API

Is it possible to wrap the steps within a Transaction so that the changes are atomic?

Answer 1

You can use TransactionTemplate in your reactive code:

private TransactionTemplate transactionTemplate;

// save to DB method
public Void saveMembers(Member m1, Member m2) {
    saveMember(m1);
    saveMember(m2);
}

// your reactive method 
public Mono<Void> saveMembersAsync(Member m1, Member m) {
    return Mono.fromCallable(() -> transactionTemplate.execute(transactionStatus -> 
        saveMembers(m1, m2)));
}