Save Data In A Method of @EventListener or @TransactionalEventListener

Question

Based on an article, Better application events in Spring Framework 4.2, I set up all related classes. The most of my code works as desired with an exception in a method of a listener.

The controller:

@PostMapping("/Foos")
public ResponseEntity<Foo> handle(@RequestBody Foo foo){
    Optional<Foo> f = fooService.save(foo);
    return f.isPresent() ?  new ResponseEntity<>(f, HttpStatus.OK) :
            new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
}

The service:

@Transactional
public Optional<Foo> save(Foo foo){
    foo = fooRepository.save(foo);
    publisher.publishEvent(new FooEvent(foo));
    return Optional.of(foo);
}

Without @Transcational in the above method, the following method won't be triggered.

The Listener

@Async
@TransactionalEventListener(condition ="#event.ok", phase = TransactionPhase.AFTER_COMMIT)
public void handle(FooEvent event){
    Product product = new Product(event.getData());
    productService.save(product);
}

The ProductService

@Transactional(propagation = Propagation.REQUIRES_NEW)
public Optional<Product> save(Product product){
    product = productRepository.save(product);
    return Optional.of(product);
}

The Product data isn't saved at all although the listener method is invoked. The code is run in a Spring Boot app BTW. I haven't found any related information online yet. How to solve this problem?

Answer 1

The solution might be different depending on what you want to achieve:

1. If you want to save product within the scope of existing transaction (where you published an event) then just change the phase to TransactionPhase.BEFORE_COMMIT and you should be good.

2. If you want to save product within the new independent transaction just after the previous one then add a @Transactional(propagation = Propagation.REQUIRES_NEW) to your handle method and left everything else as is.