Step23

03.microservices/currency-conversion-service/pom.xml

@@ -34,6 +34,17 @@
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-config</artifactId>
  </dependency>
+
+ <dependency>
+ <groupId>org.springframework.cloud</groupId>
+ <artifactId>spring-cloud-starter-feign</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.springframework.cloud</groupId>
+ <artifactId>spring-cloud-starter-ribbon</artifactId>
+ </dependency>
+
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>

03.microservices/currency-conversion-service/src/main/java/com/in28minutes/microservices/currencyconversionservice/CurrencyConversionController.java

@@ -4,6 +4,7 @@
 import java.util.HashMap;
 import java.util.Map;
 
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -12,26 +13,37 @@
 
 @RestController
 public class CurrencyConversionController {
-
+
+ @Autowired
+ private CurrencyExchangeServiceProxy proxy;
+
  @GetMapping("/currency-converter/from/{from}/to/{to}/quantity/{quantity}")
- public CurrencyConversionBean convertCurrency(@PathVariable String from,
- @PathVariable String to,
- @PathVariable BigDecimal quantity
- ){
-
+ public CurrencyConversionBean convertCurrency(@PathVariable String from, @PathVariable String to,
+ @PathVariable BigDecimal quantity) {
+
+ // Feign - Problem 1
  Map<String, String> uriVariables = new HashMap<>();
  uriVariables.put("from", from);
  uriVariables.put("to", to);
 
  ResponseEntity<CurrencyConversionBean> responseEntity = new RestTemplate().getForEntity(
- "http://localhost:8000/currency-exchange/from/{from}/to/{to}", 
- CurrencyConversionBean.class, 
- uriVariables );
-
+ "http://localhost:8000/currency-exchange/from/{from}/to/{to}", CurrencyConversionBean.class,
+ uriVariables);
+
  CurrencyConversionBean response = responseEntity.getBody();
-
- return new CurrencyConversionBean(response.getId(),from,to,response.getConversionMultiple(),
- quantity,quantity.multiply(response.getConversionMultiple()),response.getPort()); 
+
+ return new CurrencyConversionBean(response.getId(), from, to, response.getConversionMultiple(), quantity,
+ quantity.multiply(response.getConversionMultiple()), response.getPort());
+ }
+
+ @GetMapping("/currency-converter-feign/from/{from}/to/{to}/quantity/{quantity}")
+ public CurrencyConversionBean convertCurrencyFeign(@PathVariable String from, @PathVariable String to,
+ @PathVariable BigDecimal quantity) {
+
+ CurrencyConversionBean response = proxy.retrieveExchangeValue(from, to);
+
+ return new CurrencyConversionBean(response.getId(), from, to, response.getConversionMultiple(), quantity,
+ quantity.multiply(response.getConversionMultiple()), response.getPort());
  }
 
 }

03.microservices/currency-conversion-service/src/main/java/com/in28minutes/microservices/currencyconversionservice/CurrencyConversionServiceApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.feign.EnableFeignClients;
 
 @SpringBootApplication
+@EnableFeignClients("com.in28minutes.microservices.currencyconversionservice")
 public class CurrencyConversionServiceApplication {
 
  public static void main(String[] args) {

03.microservices/currency-conversion-service/src/main/java/com/in28minutes/microservices/currencyconversionservice/CurrencyExchangeServiceProxy.java

@@ -0,0 +1,15 @@
+package com.in28minutes.microservices.currencyconversionservice;
+
+import org.springframework.cloud.netflix.feign.FeignClient;
+import org.springframework.cloud.netflix.ribbon.RibbonClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+
+//@FeignClient(name="currency-exchange-service", url="localhost:8000")
+@FeignClient(name="currency-exchange-service")
+@RibbonClient(name="currency-exchange-service")
+public interface CurrencyExchangeServiceProxy {
+ @GetMapping("/currency-exchange/from/{from}/to/{to}")
+ public CurrencyConversionBean retrieveExchangeValue
+ (@PathVariable("from") String from, @PathVariable("to") String to);
+}

03.microservices/currency-conversion-service/src/main/resources/application.properties

@@ -1,2 +1,3 @@
 spring.application.name=currency-conversion-service
-server.port=8100
+server.port=8100
+currency-exchange-service.ribbon.listOfServers=http://localhost:8000,http://localhost:8001