private void notifyEachRecipient()

in ddm-notification-service/src/main/java/com/epam/digital/data/platform/notification/facade/UserNotificationFacade.java [79:90]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  private void notifyEachRecipient(boolean ignorePref, UserNotificationMessageDto message) {
    verifyNotification(message);
    parallelExecution(recipientsMaxThreadPoolSize, message.getRecipients(), recipient -> {
      var channels = getChannels(ignorePref, recipient, recipient.getChannels(), message);
      log.info("Allowed communication channels {}", channels);
      var roles = userService.getUserRoles(recipient);
      recipient.getParameters().put(RECIPIENT_ROLES_ATTRIBUTE, roles);

      parallelExecution(channelsMaxThreadPoolSize, channels,
          channel -> sendNotification(channel, recipient, message));
    });
  }