public void send()

in src/main/java/com/epam/digital/data/platform/excerpt/api/service/KafkaHelper.java [53:74]

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

  public void send(ExcerptRecord newRecord, String name, Map<String, Object> json, String templateType) {
    var event = new ExcerptEventDto(newRecord.getId(), name, json, newRecord.getSignatureRequired());
    Request<ExcerptEventDto> request = new Request<>(event);

    log.info("Send Excerpt generation Event to Kafka");
    var topic = kafkaProperties.getTopics().get(templateType);
    var future = kafkaTemplate.send(topic, request);
    future.addCallback(new ListenableFutureCallback<>() {

      @Override
      public void onSuccess(SendResult<String, Request<ExcerptEventDto>> result) {

      }

      @Override
      public void onFailure(Throwable ex) {
        newRecord.setStatus(FAILED);
        newRecord.setStatusDetails("Failed to send data for processing");
        recordRepository.save(newRecord);
      }
    });
  }