Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Transactional
- public UserEntity updateWeightByOid(String oid, int weight) {
- UserEntity user = repository.findById(oid)
- .orElseThrow(() -> GlobalException.NOT_FOUND("User not found! " + oid));
- user.setWeight(weight);
- // spring boot jpa repository's default save method
- repository.save(user);
- List<UserEmail> emails = emailService.getUserInfoSubscriberEmailsByUserOid(oid);
- CompletableFuture[] futures = emails.parallelStream().map(email -> CompletableFuture.runAsync(() ->
- createEmail(email.getAddress()))).toArray(CompletableFuture[]::new);
- CompletableFuture.allOf(futures).join();
- return user;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement