Skip to content

Commit 5a8f23a

Browse files
committed
rafactor: BulkHead Add And Worker 2 Apply #93
1 parent 81a7484 commit 5a8f23a

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

src/main/java/sopt/comfit/report/infra/feign/ResilientOpenAiFeignClient.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package sopt.comfit.report.infra.feign;
22

3+
import io.github.resilience4j.bulkhead.annotation.Bulkhead;
34
import io.github.resilience4j.circuitbreaker.CircuitBreaker;
45
import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry;
56
import io.github.resilience4j.ratelimiter.annotation.RateLimiter;
@@ -21,6 +22,7 @@ public class ResilientOpenAiFeignClient {
2122
private final OpenAiFeignClient openAiFeignClient;
2223
private final CircuitBreakerRegistry circuitBreakerRegistry;
2324

25+
@Bulkhead(name = "openai")
2426
@RateLimiter(name = "openai")
2527
@io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker(
2628
name = "openai-feign", fallbackMethod = "createReportFallback")

src/main/java/sopt/comfit/report/job/AIReportJobWorker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public class AIReportJobWorker {
3636

3737
@PostConstruct
3838
public void startWorker() {
39-
int workerCount = 3;
39+
int workerCount = 2;
4040
workers = new ArrayList<>();
4141
for (int i = 0; i < workerCount; i++) {
4242
Thread t = Thread.ofVirtual()

0 commit comments

Comments
 (0)