[AFP-25] 🚧 modify email calls. Committing to pull dev.

src/main/java/com/afp/ordermanagement/reactivekafkaservice/Sender.java

 package com.afp.ordermanagement.reactivekafkaservice;
 
 import com.afp.ordermanagement.model.Order;
+import com.afp.ordermanagement.service.EmailService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -11,6 +12,8 @@ import reactor.kafka.sender.KafkaSender;
 import reactor.kafka.sender.SenderRecord;
 import reactor.kafka.sender.SenderResult;
 
+import javax.validation.constraints.Email;
+
 
 @Service
 @Slf4j
@@ -27,6 +30,8 @@ public class Sender {
 
     public void sendOrderToWarehouse(Order orderObject) {
         log.info(String.format("##### -> Sender sending message: %s ", orderObject));
+        EmailService emailService = new EmailService();
+        log.info(emailService.emailCreator(orderObject));
         ProducerRecord<String, Order> record = new ProducerRecord<>(ORDER_TOPIC, orderObject);
         Flux<SenderResult<Order>> working = kafkaEventProducer.send(Mono.just(SenderRecord.create(record, orderObject)))
                 .doOnError(throwable -> System.out.println(throwable))

src/main/java/com/afp/ordermanagement/service/EmailService.java

@@ -4,6 +4,7 @@ import com.afp.ordermanagement.model.Order;
 import com.afp.ordermanagement.model.OrderStatus;
 import org.springframework.mail.SimpleMailMessage;
 import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.JavaMailSenderImpl;
 import org.springframework.stereotype.Service;
 
 @Service
@@ -14,6 +15,10 @@ public class EmailService {
         this.javaMailSender = javaMailSender;
     }
 
+    public EmailService() {
+        this.javaMailSender = new JavaMailSenderImpl();
+    }
+
     public void sendMail(String toEmail, String subject, String message) {
 
         SimpleMailMessage mailMessage = new SimpleMailMessage();