url values

Author: nipun-das

api-gateway/src/main/java/com/nipundas/api_gateway/routes/Routes.java

@@ -1,5 +1,6 @@
 package com.nipundas.api_gateway.routes;
 
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.gateway.server.mvc.filter.CircuitBreakerFilterFunctions;
 import org.springframework.cloud.gateway.server.mvc.handler.GatewayRouterFunctions;
 import org.springframework.cloud.gateway.server.mvc.handler.HandlerFunctions;
@@ -20,11 +21,21 @@
 @Configuration
 public class Routes {
 
+    @Value("${product.service.url}")
+    private String productServiceUrl;
+
+    @Value("${order.service.url}")
+    private String orderServiceUrl;
+
+    @Value("${inventory.service.url}")
+    private String inventoryServiceUrl;
+
+
     @Bean
     public RouterFunction<ServerResponse> productServiceRoute(){
         return route("product_service")
                 .route(RequestPredicates.path("/api/product"),
-                        HandlerFunctions.http("http://localhost:8080"))
+                        HandlerFunctions.http(productServiceUrl))
                 .filter(CircuitBreakerFilterFunctions.circuitBreaker("productServiceCircuitBreaker",
                         URI.create("forward:/fallbackRoute")))
                 .build();
@@ -34,7 +45,7 @@ public RouterFunction<ServerResponse> productServiceRoute(){
     public RouterFunction<ServerResponse> productServiceSwaggerRoute(){
         return route("product_service_swagger")
                 .route(RequestPredicates.path("/aggregate/product-service/v3/api-docs"),
-                        HandlerFunctions.http("http://localhost:8080"))
+                        HandlerFunctions.http(productServiceUrl))
                 .filter(CircuitBreakerFilterFunctions.circuitBreaker("productServiceSwaggerCircuitBreaker",
                         URI.create("forward:/fallbackRoute")))
                 .filter(setPath("/api-docs"))
@@ -45,7 +56,7 @@ public RouterFunction<ServerResponse> productServiceSwaggerRoute(){
     public RouterFunction<ServerResponse> orderServiceRoute(){
         return route("order_service")
                 .route(RequestPredicates.path("/api/order"),
-                        HandlerFunctions.http("http://localhost:8081"))
+                        HandlerFunctions.http(orderServiceUrl))
                 .filter(CircuitBreakerFilterFunctions.circuitBreaker("orderServiceCircuitBreaker",
                         URI.create("forward:/fallbackRoute")))
                 .build();
@@ -55,7 +66,7 @@ public RouterFunction<ServerResponse> orderServiceRoute(){
     public RouterFunction<ServerResponse> orderServiceSwaggerRoute(){
         return route("order_service_swagger")
                 .route(RequestPredicates.path("/aggregate/order-service/v3/api-docs"),
-                        HandlerFunctions.http("http://localhost:8081"))
+                        HandlerFunctions.http(orderServiceUrl))
                 .filter(CircuitBreakerFilterFunctions.circuitBreaker("orderServiceSwaggerCircuitBreaker",
                         URI.create("forward:/fallbackRoute")))
                 .filter(setPath("/api-docs"))
@@ -66,7 +77,7 @@ public RouterFunction<ServerResponse> orderServiceSwaggerRoute(){
     public RouterFunction<ServerResponse> inventoryServiceRoute(){
         return route("inventory_service")
                 .route(RequestPredicates.path("/api/inventory"),
-                        HandlerFunctions.http("http://localhost:8082"))
+                        HandlerFunctions.http(inventoryServiceUrl))
                 .filter(CircuitBreakerFilterFunctions.circuitBreaker("inventoryServiceCircuitBreaker",
                         URI.create("forward:/fallbackRoute")))
                 .build();
@@ -76,7 +87,7 @@ public RouterFunction<ServerResponse> inventoryServiceRoute(){
     public RouterFunction<ServerResponse> inventoryServiceSwaggerRoute(){
         return route("inventory_service_swagger")
                 .route(RequestPredicates.path("/aggregate/inventory-service/v3/api-docs"),
-                        HandlerFunctions.http("http://localhost:8082"))
+                        HandlerFunctions.http(inventoryServiceUrl))
                 .filter(CircuitBreakerFilterFunctions.circuitBreaker("inventoryServiceSwaggerCircuitBreaker",
                         URI.create("forward:/fallbackRoute")))
                 .filter(setPath("/api-docs"))

api-gateway/src/main/resources/application.properties

@@ -45,4 +45,9 @@ management.tracing.sampling.probability=1.0
 
 
 
-loki.url=http://localhost:3100/loki/api/v1/push
+loki.url=http://localhost:3100/loki/api/v1/push
+
+
+product.service.url=http://localhost:8080
+order.service.url=http://localhost:8081
+inventory.service.url=http://localhost:8082