Skip to content

Instantly share code, notes, and snippets.

Avatar
🎯
Focusing

Deepak Mehra deepakmehra10

🎯
Focusing
View GitHub Profile
View resilience4j_fallback
private Mono<ResponseEntity> getUserFallback() {
// You can fetch the value from cache here when the service is down, if the
// fallback method also cause any exception the circuit breaker will go in
// open state accordingly after multiple failed requests(Please check
// configurations for that).
return Mono.just(ResponseEntity.ok(User.builder().id("1").name("Deepak").build()));
}
View resilience4j_with_fallback
// With Fallback
@GetMapping("/fallback/users")
@CircuitBreaker(name = USER_SERVICE, fallbackMethod = "getUserFallback")
public Mono<ResponseEntity> getUserWithFallback() {
// This will cause the exception and control will be transferred to fallback method.
return Mono.error(new TimeoutException("Timeout exception occurred."));
}
View resilience4j_failure
// Failure
@GetMapping("failure/users")
@CircuitBreaker(name = USER_SERVICE)
public Mono<ResponseEntity> getUserWithFailure() {
// This will cause the circuit breaker to go in an open state.
return Mono.error(new TimeoutException("Timeout exception occurred."));
}
View resilience4j_success
// Success
@GetMapping("success/users")
@CircuitBreaker(name = USER_SERVICE)
public Mono<ResponseEntity> getUser(@PathVariable String id) throws Exception {
return Mono.just(ResponseEntity.ok(User.builder().id("1").name("Deepak").build()));
}
View resilience4j_application
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
View resilience4j_dependency
<dependency>
<groupId>io.github.resilience4j</groupId>
<artifactId>resilience4j-spring-boot2</artifactId>
<version>1.5.0</version>
</dependency>
View future-factory
CompletableFuture name = CompletableFuture.completedFuture("Deepak");
CompletionStage name With CompletionStage = CompletableFuture.completedStage("Deepak");
CompletableFuture failedFuture = failedFuture(new TimeoutException());
System.out.println(failedFuture.join());
View complete-on-timeout
public class CompleteOnTimeoutDemo {
public static void main(String[] args) {
CompletableFuture orTimeout = CompletableFuture.supplyAsync(() -> {
try {
return getUsers();
} catch (Exception ex) {
System.out.println(ex.getMessage());
return null;
}
})
View or-timeout
public class OrTimeoutDemo {
public static void main(String[] args) {
CompletableFuture orTimeout = CompletableFuture.supplyAsync(() -> {
try {
return getUsers();
} catch (Exception ex) {
System.out.println(ex.getMessage());
return null;
}
})
View complete-async
CompletableFuture completableFuture = new CompletableFuture();
CompletableFuture nameFuture = completableFuture.completeAsync(() -> "Deepak");
// Should be avoided, only for demonstration purpose
System.out.println(nameFuture.join());