LokeshAggarwal2

resilience4j.circuitbreaker:
  instances:
    service1:
      registerHealthIndicator: true
      ringBufferSizeInClosedState: 5
      ringBufferSizeInHalfOpenState: 3
      waitDurationInOpenState: 10s
      failureRateThreshold: 50
      recordExceptions:
        - org.springframework.web.client.ResourceAccessException

LokeshAggarwal2

@RestController
public class UserRegistrationController {

    @PostMapping("/register/seller")
    public String registerAsSeller(@RequestBody SellerDto sellerDto) {
        return UserRegistrationResilience4j.registerSeller(sellerDto);
    }
    
}

LokeshAggarwal2

@Service
public class UserRegistrationResilience4j {

  @CircuitBreaker(name = "service1", fallbackMethod = "fallbackForRegisterSeller")
  public String registerSeller(SellerDto sellerDto) {
        String response = restTemplate.postForObject("/addSeller", sellerDto, String.class);
        return response;
  }
  
   public String fallbackForRegisterSeller(SellerDto sellerDto, Throwable t) {

LokeshAggarwal2

resilience4j.bulkhead:
  instances:
    bulkheadService1:
      maxWaitDuration: 1000ms
      maxConcurrentCall: 2

resilience4j.thread-pool-bulkhead:
  instances:
    bulkheadService1:
      maxThreadPoolSize: 1

LokeshAggarwal2

@RestController
public class UserRegistrationController {
@PostMapping("/register/seller")
    public String registerAsSeller(@RequestBody SellerDto sellerDto) throws InterruptedException {
        String registerSeller = null;
        for (int i = 0; i < 100; i++) {
            long start = System.currentTimeMillis();
            new Thread(() -> {
                try {
                    userRegistrationResilience4j.registerSeller(sellerDto);

LokeshAggarwal2

@Service
public class UserRegistrationResilience4j {
    @Bulkhead(name = "bulkheadService1", fallbackMethod = "bulkHeadFallback")
    public String registerSeller(SellerDto sellerDto) throws InterruptedException {
        String response = restTemplate.postForObject("/addSeller", sellerDto, String.class);
        return response;
    }
    
    public String bulkHeadFallback(SellerDto sellerDto, Throwable t) {
        logger.error("Inside bulkHeadFallback, cause - {}", t.toString());

LokeshAggarwal2

public abstract class Car {
    protected String color;
    public abstract void setColor();

    public void getColor() {
        System.out.println("car color:"+ color);
    }
}

LokeshAggarwal2

 public class Hyundai extends Car{
     @Override
     public void setColor() {
         color = "Hyundai car color is black";
     }
 }

LokeshAggarwal2

 public class Maruti extends Car{
     @Override
     public void setColor() {
         color = "Maruti car color is Red";
     }
 }

LokeshAggarwal2

public  class Tata extends Car{
     @Override
     public void setColor() {
         color = "Tata color is Grey";
     }
 }