modified service

Author: nipun-das

notification-service/src/main/java/com/nipundas/notification_service/NotificationServiceApplication.java renamed to notification-service/src/main/java/com/nipundas/microservices/NotificationServiceApplication.java

@@ -1,4 +1,4 @@
-package com.nipundas.notification_service;
+package com.nipundas.microservices.order;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

notification-service/src/main/java/com/nipundas/notification_service/notification/service/NotificationService.java renamed to notification-service/src/main/java/com/nipundas/microservices/notification/service/NotificationService.java

@@ -1,8 +1,8 @@
-package com.nipundas.notification_service.notification.service;
+package com.nipundas.microservices.notification.service;
 
 
 
-import com.nipundas.notification_service.order.event.OrderPlacedEvent;
+//import com.nipundas.microservices.order.event.OrderPlacedEvent;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaListener;
@@ -19,8 +19,8 @@ public class NotificationService {
 
     private final JavaMailSender javaMailSender;
 
-    @KafkaListener(topics="order-placed")
-    public void listen(OrderPlacedEvent orderPlacedEvent){
+    @KafkaListener(topics="order-placed",groupId = "notification-service")
+    public void listen(com.nipundas.microservices.order.event.OrderPlacedEvent orderPlacedEvent){
         log.info("Got message from order-placed kafkaTopic ",orderPlacedEvent);
 
         //sending mail

notification-service/src/main/java/com/nipundas/notification_service/avro.order-placed.avsc renamed to notification-service/src/main/java/com/nipundas/microservices/order/avro.order-placed.avsc

@@ -1,4 +1,4 @@
-package com.nipundas.notification_service.order.event;
+package com.nipundas.microservices.order.order.event;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

notification-service/src/main/java/com/nipundas/notification_service/order/event/OrderPlacedEvent.java renamed to notification-service/src/main/java/com/nipundas/microservices/order/event/OrderPlacedEvent.java

@@ -1,4 +1,4 @@
-package com.nipundas.notification_service;
+package com.nipundas.microservices;
 
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;

notification-service/src/test/java/com/nipundas/notification_service/NotificationServiceApplicationTests.java renamed to notification-service/src/test/java/com/nipundas/microservices/order/NotificationServiceApplicationTests.java

@@ -1,4 +1,4 @@
-package com.nipundas.notification_service;
+package com.nipundas.microservices;
 
 import org.springframework.boot.SpringApplication;
 

notification-service/src/test/java/com/nipundas/notification_service/TestNotificationServiceApplication.java renamed to notification-service/src/test/java/com/nipundas/microservices/order/TestNotificationServiceApplication.java

@@ -1,4 +1,4 @@
-package com.nipundas.notification_service;
+package com.nipundas.microservices;
 
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;

notification-service/src/test/java/com/nipundas/notification_service/TestcontainersConfiguration.java renamed to notification-service/src/test/java/com/nipundas/microservices/order/TestcontainersConfiguration.java

@@ -1,4 +1,4 @@
-package com.nipundas.order_service;
+package com.nipundas.microservices;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

order-service/mysql/binlog.000010

@@ -1,13 +1,10 @@
-package com.nipundas.order_service.client;
+package com.nipundas.microservices.client;
 
 import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
 import io.github.resilience4j.retry.annotation.Retry;
 
-import lombok.extern.slf4j.Slf4j;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.service.annotation.GetExchange;