Advertisement
amitsen01ei

Untitled

Jul 7th, 2025
362
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 0.70 KB | Source Code | 0 0
  1. @Transactional
  2.     public UserEntity updateWeightByOid(String oid, int weight) {
  3.         UserEntity user = repository.findById(oid)
  4.                 .orElseThrow(() -> GlobalException.NOT_FOUND("User not found! " + oid));
  5.         user.setWeight(weight);
  6.         // spring boot jpa repository's default save method
  7.         repository.save(user);
  8.  
  9.         List<UserEmail> emails = emailService.getUserInfoSubscriberEmailsByUserOid(oid);
  10.         CompletableFuture[] futures = emails.parallelStream().map(email -> CompletableFuture.runAsync(() ->
  11.                 createEmail(email.getAddress()))).toArray(CompletableFuture[]::new);
  12.  
  13.         CompletableFuture.allOf(futures).join();
  14.         return user;
  15.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement