Step44

03.microservices/limits-service/pom.xml

@@ -26,10 +26,17 @@
  </properties>
 
  <dependencies>
+
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-config</artifactId>
  </dependency>
+
+ <dependency>
+ <groupId>org.springframework.cloud</groupId>
+ <artifactId>spring-cloud-starter-hystrix</artifactId>
+ </dependency>
+
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-bus-amqp</artifactId>

03.microservices/limits-service/src/main/java/com/in28minutes/microservices/limitsservice/LimitsConfigurationController.java

@@ -5,6 +5,7 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import com.in28minutes.microservices.limitsservice.bean.LimitConfiguration;
+import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
 
 @RestController
 public class LimitsConfigurationController {
@@ -18,4 +19,15 @@ public LimitConfiguration retrieveLimitsFromConfigurations() {
  configuration.getMinimum());
  return limitConfiguration;
  }
+
+ @GetMapping("/fault-tolerance-example")
+ @HystrixCommand(fallbackMethod="fallbackRetrieveConfiguration")
+ public LimitConfiguration retrieveConfiguration() {
+ throw new RuntimeException("Not available");
+ }
+
+ public LimitConfiguration fallbackRetrieveConfiguration() {
+ return new LimitConfiguration(999, 9);
+ }
+
 }

03.microservices/limits-service/src/main/java/com/in28minutes/microservices/limitsservice/LimitsServiceApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 
 @SpringBootApplication
+@EnableHystrix
 public class LimitsServiceApplication {
  public static void main(String[] args) {
  SpringApplication.run(LimitsServiceApplication.class, args);