Adds circuit breaker

applications/allocations-server/build.gradle

@@ -2,4 +2,5 @@ apply from: "$projectDir/../server.gradle"
 
 dependencies {
     compile project(":components:allocations")
+    compile "io.pivotal.spring.cloud:spring-cloud-services-starter-circuit-breaker"
 }

applications/allocations-server/src/main/java/io/pivotal/pal/tracker/allocations/App.java

@@ -3,6 +3,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
@@ -11,6 +12,7 @@
 import java.util.TimeZone;
 
 @EnableEurekaClient
+@EnableCircuitBreaker
 @SpringBootApplication
 @ComponentScan({"io.pivotal.pal.tracker.allocations", "io.pivotal.pal.tracker.restsupport"})
 public class App {

applications/allocations-server/src/main/resources/application.properties

@@ -5,4 +5,6 @@ spring.datasource.username=tracker
 spring.datasource.url=jdbc:mysql://localhost:3306/tracker_allocations_dev?useSSL=false&useTimezone=true&serverTimezone=UTC&useLegacyDatetimeCode=false
 registration.server.endpoint=http://registration-server
 security.basic.enabled=false
-management.security.enabled=false
+management.security.enabled=false
+
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

applications/allocations-server/src/test/resources/application.properties

@@ -6,3 +6,5 @@ spring.datasource.url=jdbc:mysql://localhost:3306/tracker_allocations_test?useSS
 registration.server.endpoint=http://registration-server
 security.basic.enabled=false
 management.security.enabled=false
+
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

applications/backlog-server/build.gradle

@@ -2,4 +2,5 @@ apply from: "$projectDir/../server.gradle"
 
 dependencies {
     compile project(":components:backlog")
+    compile "io.pivotal.spring.cloud:spring-cloud-services-starter-circuit-breaker"
 }

applications/backlog-server/src/main/java/io/pivotal/pal/tracker/backlog/App.java

@@ -3,6 +3,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
@@ -11,6 +12,7 @@
 import java.util.TimeZone;
 
 @EnableEurekaClient
+@EnableCircuitBreaker
 @SpringBootApplication
 @ComponentScan({"io.pivotal.pal.tracker.backlog", "io.pivotal.pal.tracker.restsupport"})
 public class App {

applications/backlog-server/src/main/resources/application.properties

@@ -5,4 +5,6 @@ spring.datasource.username=tracker
 spring.datasource.url=jdbc:mysql://localhost:3306/tracker_backlog_dev?useSSL=false&useTimezone=true&serverTimezone=UTC&useLegacyDatetimeCode=false
 registration.server.endpoint=http://registration-server
 security.basic.enabled=false
-management.security.enabled=false
+management.security.enabled=false
+
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

applications/backlog-server/src/test/resources/application.properties

@@ -6,3 +6,5 @@ spring.datasource.url=jdbc:mysql://localhost:3306/tracker_backlog_test?useSSL=fa
 registration.server.endpoint=http://registration-server
 security.basic.enabled=false
 management.security.enabled=false
+
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

applications/timesheets-server/build.gradle

@@ -2,4 +2,5 @@ apply from: "$projectDir/../server.gradle"
 
 dependencies {
     compile project(":components:timesheets")
+    compile "io.pivotal.spring.cloud:spring-cloud-services-starter-circuit-breaker"
 }

applications/timesheets-server/src/main/java/io/pivotal/pal/tracker/timesheets/App.java

@@ -3,6 +3,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
@@ -11,6 +12,7 @@
 import java.util.TimeZone;
 
 @EnableEurekaClient
+@EnableCircuitBreaker
 @SpringBootApplication
 @ComponentScan({"io.pivotal.pal.tracker.timesheets", "io.pivotal.pal.tracker.restsupport"})
 public class App {

applications/timesheets-server/src/main/resources/application.properties

@@ -6,4 +6,6 @@ spring.datasource.url=jdbc:mysql://localhost:3306/tracker_timesheets_dev?useSSL=
 registration.server.endpoint=http://registration-server
 
 security.basic.enabled=false
-management.security.enabled=false
+management.security.enabled=false
+
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

applications/timesheets-server/src/test/resources/application.properties

@@ -6,3 +6,5 @@ spring.datasource.url=jdbc:mysql://localhost:3306/tracker_timesheets_test?useSSL
 registration.server.endpoint=http://registration-server
 security.basic.enabled=false
 management.security.enabled=false
+
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

components/allocations/build.gradle

@@ -1,6 +1,7 @@
 dependencies {
     compile project(":components:rest-support")
     compile "org.springframework:spring-jdbc:$springVersion"
+    compile "com.netflix.hystrix:hystrix-javanica:1.5.6"
 
     testCompile project(":components:test-support")
 }

components/allocations/src/main/java/io/pivotal/pal/tracker/allocations/ProjectClient.java

@@ -1,18 +1,36 @@
 package io.pivotal.pal.tracker.allocations;
 
+import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.web.client.RestOperations;
 
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
 public class ProjectClient {
 
+    private final Logger logger = LoggerFactory.getLogger(getClass());
+    private final Map<Long, ProjectInfo> projectsCache = new ConcurrentHashMap<>();
     private final RestOperations restOperations;
-    private final String registrationServerEndpoint;
+    private final String endpoint;
 
     public ProjectClient(RestOperations restOperations, String registrationServerEndpoint) {
-        this.restOperations= restOperations;
-        this.registrationServerEndpoint = registrationServerEndpoint;
+        this.restOperations = restOperations;
+        this.endpoint = registrationServerEndpoint;
     }
 
+    @HystrixCommand(fallbackMethod = "getProjectFromCache")
     public ProjectInfo getProject(long projectId) {
-        return restOperations.getForObject(registrationServerEndpoint + "/projects/" + projectId, ProjectInfo.class);
+        ProjectInfo project = restOperations.getForObject(endpoint + "/projects/" + projectId, ProjectInfo.class);
+
+        projectsCache.put(projectId, project);
+
+        return project;
+    }
+
+    public ProjectInfo getProjectFromCache(long projectId) {
+        logger.info("Getting project with id {} from cache", projectId);
+        return projectsCache.get(projectId);
     }
-}
+}

components/backlog/build.gradle

@@ -1,6 +1,7 @@
 dependencies {
     compile project(":components:rest-support")
     compile "org.springframework:spring-jdbc:$springVersion"
+    compile "com.netflix.hystrix:hystrix-javanica:1.5.6"
 
     testCompile project(":components:test-support")
 }

components/backlog/src/main/java/io/pivotal/pal/tracker/backlog/ProjectClient.java

@@ -1,9 +1,17 @@
 package io.pivotal.pal.tracker.backlog;
 
+import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.web.client.RestOperations;
 
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
 public class ProjectClient {
 
+    private final Logger logger = LoggerFactory.getLogger(getClass());
+    private final Map<Long, ProjectInfo> projectsCache = new ConcurrentHashMap<>();
     private final RestOperations restOperations;
     private final String endpoint;
 
@@ -12,7 +20,17 @@ public ProjectClient(RestOperations restOperations, String registrationServerEnd
         this.endpoint = registrationServerEndpoint;
     }
 
+    @HystrixCommand(fallbackMethod = "getProjectFromCache")
     public ProjectInfo getProject(long projectId) {
-        return restOperations.getForObject(endpoint + "/projects/" + projectId, ProjectInfo.class);
+        ProjectInfo project = restOperations.getForObject(endpoint + "/projects/" + projectId, ProjectInfo.class);
+
+        projectsCache.put(projectId, project);
+
+        return project;
+    }
+
+    public ProjectInfo getProjectFromCache(long projectId) {
+        logger.info("Getting project with id {} from cache", projectId);
+        return projectsCache.get(projectId);
     }
-}
+}

components/timesheets/build.gradle

@@ -1,6 +1,7 @@
 dependencies {
     compile project(":components:rest-support")
     compile "org.springframework:spring-jdbc:$springVersion"
+    compile "com.netflix.hystrix:hystrix-javanica:1.5.6"
 
     testCompile project(":components:test-support")
 }

components/timesheets/src/main/java/io/pivotal/pal/tracker/timesheets/ProjectClient.java

@@ -1,9 +1,17 @@
 package io.pivotal.pal.tracker.timesheets;
 
+import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.web.client.RestOperations;
 
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
 public class ProjectClient {
 
+    private final Logger logger = LoggerFactory.getLogger(getClass());
+    private final Map<Long, ProjectInfo> projectsCache = new ConcurrentHashMap<>();
     private final RestOperations restOperations;
     private final String endpoint;
 
@@ -12,7 +20,17 @@ public ProjectClient(RestOperations restOperations, String registrationServerEnd
         this.endpoint = registrationServerEndpoint;
     }
 
+    @HystrixCommand(fallbackMethod = "getProjectFromCache")
     public ProjectInfo getProject(long projectId) {
-        return restOperations.getForObject(endpoint + "/projects/" + projectId, ProjectInfo.class);
+        ProjectInfo project = restOperations.getForObject(endpoint + "/projects/" + projectId, ProjectInfo.class);
+
+        projectsCache.put(projectId, project);
+
+        return project;
+    }
+
+    public ProjectInfo getProjectFromCache(long projectId) {
+        logger.info("Getting project with id {} from cache", projectId);
+        return projectsCache.get(projectId);
     }
-}
+}

manifest-allocations.yml

@@ -10,3 +10,4 @@ applications:
   services:
   - tracker-allocations-database
   - tracker-service-registry
+  - tracker-circuit-breaker-dashboard

manifest-backlog.yml

@@ -10,3 +10,4 @@ applications:
   services:
   - tracker-backlog-database
   - tracker-service-registry
+  - tracker-circuit-breaker-dashboard

manifest-timesheets.yml

@@ -10,3 +10,4 @@ applications:
   services:
   - tracker-timesheets-database
   - tracker-service-registry
+  - tracker-circuit-breaker-dashboard