implement customer producer with rabbitmq

Author: hamidreza-ka

customer/src/main/java/com/hrk/customer/CustomerApplication.java

@@ -5,7 +5,12 @@
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 
-@SpringBootApplication
+@SpringBootApplication(
+        scanBasePackages = {
+                "com.hrk.customer",
+                "com.hrk.amqp"
+        }
+)
 @EnableEurekaClient
 @EnableFeignClients(
         basePackages = "com.hrk.clients"

customer/src/main/java/com/hrk/customer/CustomerService.java

@@ -1,14 +1,14 @@
 package com.hrk.customer;
 
+import com.hrk.amqp.RabbitMQMessageProducer;
 import com.hrk.clients.fraud.FraudCheckResponse;
 import com.hrk.clients.fraud.FraudClient;
-import com.hrk.clients.notification.NotificationClient;
 import com.hrk.clients.notification.NotificationRequest;
 import org.springframework.stereotype.Service;
-import org.springframework.web.client.RestTemplate;
 
 @Service
-public record CustomerService(CustomerRepository repository, FraudClient fraudClient, NotificationClient notificationClient) {
+public record CustomerService(CustomerRepository repository, FraudClient fraudClient,
+                              RabbitMQMessageProducer rabbitMQMessageProducer) {
     public void registerCustomer(CustomerRegistrationRequest request) {
         Customer customer = Customer.builder()
                 .firstName(request.firstName())
@@ -24,12 +24,11 @@ public void registerCustomer(CustomerRegistrationRequest request) {
         if (fraudCheckResponse.isFraudster())
             throw new IllegalStateException("fraudster");
 
-        notificationClient.sendNotification(
-                new NotificationRequest(
-                        customer.getId(),
-                        customer.getEmail(),
-                        String.format("Hi %s welcome to HRK Academy...", customer.getFirstName())
-                )
+        NotificationRequest notificationRequest = new NotificationRequest(
+                customer.getId(),
+                customer.getEmail(),
+                String.format("Hi %s welcome to HRK Academy...", customer.getFirstName())
         );
+        rabbitMQMessageProducer.publish(notificationRequest, "internal.exchange", "internal.notification.routing-key");
     }
 }

customer/src/main/resources/application.yml

@@ -22,6 +22,9 @@ spring:
   zipkin:
     base-url: http://localhost:9411
 
+  rabbitmq:
+    addresses: localhost:5672
+
 eureka:
   client:
     service-url:

notification/src/main/java/com/hrk/notification/rabbitmq/NotificationConsumer.java

@@ -0,0 +1,18 @@
+package com.hrk.notification.rabbitmq;
+
+import com.hrk.clients.notification.NotificationRequest;
+import com.hrk.notification.NotificationService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public record NotificationConsumer(NotificationService notificationService) {
+
+    @RabbitListener(queues = "${rabbitmq.queue.notification}")
+    public void consumer(NotificationRequest notificationRequest){
+        log.info("Consumed {} from queue", notificationRequest);
+        notificationService.send(notificationRequest);
+    }
+}