serv.java

@Service
public class StoreService implements StoreManagementUseCase {
  private final StorePort storePort;
  private final UpdateStoreCountInZipCodePort updateStoreCountInZipCodePort;

  @Autowired
  public StoreService(StorePort storePort, UpdateStoreCountInZipCodePort updateStoreCountInZipCodePort) {
    this.storePort = storePort;
    this.updateStoreCountInZipCodePort = updateStoreCountInZipCodePort;
  }

  @Override
  @Transactional
  public Mono<Store> addStore(Store store) {
    if (store.isValid()) {
      final Mono<Store> result = storePort.addStore(store);
      updateStoreCountInZipCodePort.incrementStoreCount(store.getLocation().getZipCode());
      return result;
    }
    return Mono.error(InvalidAttributesException::new);
  }
}