public void send()

in ddm-notification-service-core/src/main/java/com/epam/digital/data/platform/notification/core/producer/AbstractNotificationProducer.java [40:50]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public void send(Recipient recipient, UserNotificationMessageDto message) {
    log.info("Sending {} notification Kafka message", getChannel().getValue());
    var notificationMessageDto = createMessageDto(recipient, message);

    if (Objects.nonNull(notificationMessageDto)) {
      kafkaTemplate.send(topic, notificationMessageDto);
      log.info("{} notification Kafka message is sent, context: {}",
          getChannel().getValue(),
          message.getContext());
    }
  }